Skip to content

Fix timeout type#540

Merged
AlexInLog merged 1 commit into
v2from
fix_timeout_type
Mar 8, 2024
Merged

Fix timeout type#540
AlexInLog merged 1 commit into
v2from
fix_timeout_type

Conversation

@AlexInLog

Copy link
Copy Markdown
Owner

No description provided.

@github-actions

github-actions Bot commented Mar 8, 2024

Copy link
Copy Markdown
Contributor

BENCHMARK RESULTS (AUTOGENERATED)

ci-ubuntu-gcc

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 308.51 ns 2.16 ns 2.16 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 305.60 ns 2.16 ns 2.16 ns 1.00

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 692.03 ns 0.62 ns 0.62 ns 1.00
from array of 1 - create + subscribe + current_thread 1038.93 ns 4.63 ns 4.63 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2264.34 ns 115.82 ns 129.58 ns 0.89
defer from array of 1 - defer + create + subscribe + immediate 734.28 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2113.85 ns 59.23 ns 59.19 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3008.72 ns 32.75 ns 32.73 ns 1.00

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1072.31 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 880.46 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1023.11 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 848.62 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+first()+subscribe 1246.18 ns 0.62 ns 0.62 ns 1.00
immediate_just(1,2)+last()+subscribe 918.34 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1105.10 ns 18.52 ns 18.83 ns 0.98

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 267.18 ns 2.16 ns 2.16 ns 1.00
current_thread scheduler create worker + schedule 371.06 ns 6.84 ns 6.79 ns 1.01
current_thread scheduler create worker + schedule + recursive schedule 823.39 ns 64.31 ns 64.21 ns 1.00

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 854.02 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 888.91 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2339.36 ns 161.69 ns 163.57 ns 0.99
immediate_just+buffer(2)+subscribe 1532.86 ns 14.21 ns 14.51 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 2400.00 ns 1072.32 ns 1125.88 ns 0.95

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 828.76 ns - - 0.00
immediate_just+take_while(true)+subscribe 823.71 ns 0.31 ns 0.31 ns 1.00

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1973.50 ns 0.31 ns 0.31 ns 1.00

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 3390.05 ns 176.86 ns 175.90 ns 1.01
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3653.97 ns 171.11 ns 168.05 ns 1.02
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 142.25 ns 132.66 ns 1.07
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3565.82 ns 1017.99 ns 1126.58 ns 0.90
immediate_just(1) + zip(immediate_just(2)) + subscribe 2181.74 ns 218.80 ns 212.19 ns 1.03

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 34.57 ns 12.03 ns 11.72 ns 1.03

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1409.44 ns 15.75 ns 15.74 ns 1.00
basic sample with immediate scheduler 1404.32 ns 5.55 ns 5.55 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 909.24 ns 0.31 ns 0.31 ns 1.00

Error Handling Operators

name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 1059.39 ns 121.63 ns 122.92 ns 0.99

ci-macos

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1070.66 ns 5.41 ns 5.61 ns 0.96
Subscribe empty callbacks to empty observable via pipe operator 1063.83 ns 5.38 ns 5.47 ns 0.98

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2312.43 ns 0.44 ns 0.46 ns 0.96
from array of 1 - create + subscribe + current_thread 2953.23 ns 8.94 ns 9.20 ns 0.97
concat_as_source of just(1 immediate) create + subscribe 6822.41 ns 400.23 ns 418.66 ns 0.96
defer from array of 1 - defer + create + subscribe + immediate 2372.64 ns 0.28 ns 0.30 ns 0.94
interval - interval + take(3) + subscribe + immediate 6381.32 ns 108.52 ns 97.52 ns 1.11
interval - interval + take(3) + subscribe + current_thread 7772.58 ns 76.71 ns 62.35 ns 1.23

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 3797.01 ns 0.30 ns 0.28 ns 1.07
immediate_just+filter(true)+subscribe 2511.42 ns 0.30 ns 0.29 ns 1.03
immediate_just(1,2)+skip(1)+subscribe 3666.90 ns 0.29 ns 0.28 ns 1.03
immediate_just(1,1,2)+distinct_until_changed()+subscribe 2436.82 ns 0.56 ns 0.57 ns 0.98
immediate_just(1,2)+first()+subscribe 4135.82 ns 0.31 ns 0.30 ns 1.01
immediate_just(1,2)+last()+subscribe 2915.51 ns 0.28 ns 0.28 ns 1.00
immediate_just+take_last(1)+subscribe 4082.80 ns 81.31 ns 78.01 ns 1.04

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 999.16 ns 5.76 ns 5.83 ns 0.99
current_thread scheduler create worker + schedule 1296.37 ns 15.18 ns 15.50 ns 0.98
current_thread scheduler create worker + schedule + recursive schedule 2271.46 ns 158.81 ns 167.37 ns 0.95

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 2510.38 ns 0.28 ns 0.32 ns 0.88
immediate_just+scan(10, std::plus)+subscribe 2819.17 ns 0.60 ns 0.59 ns 1.02
immediate_just+flat_map(immediate_just(v*2))+subscribe 6516.04 ns 467.35 ns 473.49 ns 0.99
immediate_just+buffer(2)+subscribe 3557.81 ns 77.37 ns 74.08 ns 1.04
immediate_just+window(2)+subscribe + subscsribe inner 7006.27 ns 3124.93 ns 2827.59 ns 1.11

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 2479.70 ns - - 0.00
immediate_just+take_while(true)+subscribe 2502.96 ns 0.28 ns 0.29 ns 0.97

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 5852.41 ns 0.28 ns 0.29 ns 0.96

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 9436.37 ns 554.38 ns 552.23 ns 1.00
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 10212.16 ns 528.71 ns 545.05 ns 0.97
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 520.28 ns 536.20 ns 0.97
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 10007.43 ns 2354.52 ns 2415.15 ns 0.97
immediate_just(1) + zip(immediate_just(2)) + subscribe 6449.92 ns 967.06 ns 1014.95 ns 0.95

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 98.72 ns 65.84 ns 63.12 ns 1.04

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 3471.90 ns 46.57 ns 47.17 ns 0.99
basic sample with immediate scheduler 3409.30 ns 6.43 ns 6.85 ns 0.94

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 2893.90 ns 0.28 ns 0.30 ns 0.94

Error Handling Operators

name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 8263.57 ns 5003.62 ns 5810.48 ns 0.86

ci-ubuntu-clang

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 272.02 ns 0.88 ns 0.88 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 271.83 ns 0.88 ns 0.88 ns 1.00

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 563.49 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 822.25 ns 5.56 ns 5.55 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 1904.50 ns 113.04 ns 112.88 ns 1.00
defer from array of 1 - defer + create + subscribe + immediate 581.35 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 1563.48 ns 58.35 ns 58.31 ns 1.00
interval - interval + take(3) + subscribe + current_thread 2092.63 ns 31.47 ns 31.47 ns 1.00

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 937.68 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 659.00 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 849.37 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 689.44 ns 0.62 ns 0.62 ns 1.00
immediate_just(1,2)+first()+subscribe 1071.70 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+last()+subscribe 720.21 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 950.77 ns 0.31 ns 0.31 ns 1.00

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 193.94 ns 0.88 ns 0.88 ns 1.00
current_thread scheduler create worker + schedule 301.94 ns 5.58 ns 5.89 ns 0.95
current_thread scheduler create worker + schedule + recursive schedule 614.60 ns 61.55 ns 58.68 ns 1.05

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 670.26 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 714.12 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 1756.87 ns 122.53 ns 121.82 ns 1.01
immediate_just+buffer(2)+subscribe 1346.06 ns 13.89 ns 14.50 ns 0.96
immediate_just+window(2)+subscribe + subscsribe inner 2167.02 ns 809.27 ns 822.79 ns 0.98

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 648.78 ns - - 0.00
immediate_just+take_while(true)+subscribe 644.23 ns 0.31 ns 0.31 ns 1.00

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1586.04 ns 0.31 ns 0.31 ns 1.00

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 2505.89 ns 126.46 ns 126.45 ns 1.00
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3040.36 ns 120.82 ns 120.99 ns 1.00
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 112.17 ns 112.71 ns 1.00
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 2685.10 ns 723.93 ns 728.22 ns 0.99
immediate_just(1) + zip(immediate_just(2)) + subscribe 1825.08 ns 174.27 ns 177.33 ns 0.98

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 50.88 ns 14.49 ns 14.50 ns 1.00

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1027.51 ns 13.58 ns 13.58 ns 1.00
basic sample with immediate scheduler 1045.19 ns 5.86 ns 5.86 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 739.60 ns 0.31 ns 0.31 ns 1.00

Error Handling Operators

name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 842.86 ns 127.38 ns 126.92 ns 1.00

ci-windows

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 576.24 ns 4.94 ns 4.93 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 598.44 ns 4.93 ns 4.94 ns 1.00

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1181.64 ns 5.55 ns 5.55 ns 1.00
from array of 1 - create + subscribe + current_thread 1445.09 ns 18.86 ns 18.51 ns 1.02
concat_as_source of just(1 immediate) create + subscribe 4718.87 ns 171.84 ns 174.87 ns 0.98
defer from array of 1 - defer + create + subscribe + immediate 1216.22 ns 5.86 ns 5.86 ns 1.00
interval - interval + take(3) + subscribe + immediate 3104.44 ns 133.68 ns 133.63 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3446.69 ns 58.72 ns 58.77 ns 1.00

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1853.30 ns 12.87 ns 12.87 ns 1.00
immediate_just+filter(true)+subscribe 1715.29 ns 11.71 ns 11.73 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1788.40 ns 13.20 ns 13.21 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 1371.68 ns 15.78 ns 15.77 ns 1.00
immediate_just(1,2)+first()+subscribe 2079.96 ns 12.96 ns 12.95 ns 1.00
immediate_just(1,2)+last()+subscribe 1504.85 ns 14.19 ns 14.11 ns 1.01
immediate_just+take_last(1)+subscribe 2038.56 ns 58.89 ns 58.89 ns 1.00

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 486.68 ns 6.18 ns 6.18 ns 1.00
current_thread scheduler create worker + schedule 670.16 ns 18.22 ns 18.22 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 1104.89 ns 108.31 ns 108.35 ns 1.00

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 1326.39 ns 11.71 ns 11.31 ns 1.04
immediate_just+scan(10, std::plus)+subscribe 1442.84 ns 21.59 ns 21.58 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 3958.08 ns 230.05 ns 227.97 ns 1.01
immediate_just+buffer(2)+subscribe 2318.09 ns 58.05 ns 58.32 ns 1.00
immediate_just+window(2)+subscribe + subscsribe inner 4078.84 ns 1554.09 ns 1589.69 ns 0.98

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 1333.49 ns 11.46 ns 11.44 ns 1.00
immediate_just+take_while(true)+subscribe 1320.07 ns 11.72 ns 11.72 ns 1.00

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 4197.89 ns 8.02 ns 8.02 ns 1.00

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 5187.88 ns 247.76 ns 245.51 ns 1.01
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 6544.83 ns 231.59 ns 234.62 ns 0.99
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 238.35 ns 234.29 ns 1.02
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 6404.60 ns 1043.77 ns 960.87 ns 1.09
immediate_just(1) + zip(immediate_just(2)) + subscribe 3924.39 ns 542.49 ns 534.06 ns 1.02

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 36.44 ns 26.21 ns 26.20 ns 1.00

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1896.34 ns 59.75 ns 59.94 ns 1.00
basic sample with immediate scheduler 1886.56 ns 37.06 ns 37.03 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 1477.88 ns 19.93 ns 19.94 ns 1.00

Error Handling Operators

name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 1943.80 ns 339.12 ns 341.71 ns 0.99

@sonarqubecloud

sonarqubecloud Bot commented Mar 8, 2024

Copy link
Copy Markdown

@AlexInLog AlexInLog merged commit a452bce into v2 Mar 8, 2024
@AlexInLog AlexInLog deleted the fix_timeout_type branch March 8, 2024 18:17
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant