Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Move presets #589

Merged
merged 2 commits into from
May 28, 2024
Merged

Move presets #589

merged 2 commits into from
May 28, 2024

Conversation

victimsnino
Copy link
Owner

No description provided.

@victimsnino victimsnino marked this pull request as ready for review May 27, 2024 21:18
Copy link
Contributor

BENCHMARK RESULTS (AUTOGENERATED)

ci-ubuntu-gcc

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 304.08 ns 2.19 ns 2.19 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 324.80 ns 2.16 ns 2.16 ns 1.00

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 698.95 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 1040.14 ns 3.42 ns 3.43 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2310.12 ns 131.80 ns 135.25 ns 0.97
defer from array of 1 - defer + create + subscribe + immediate 775.63 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2178.78 ns 59.19 ns 59.25 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3063.90 ns 32.43 ns 32.43 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 29685.20 ns 27644.68 ns 27866.66 ns 0.99
from array of 1000 - create + as_blocking + subscribe + new_thread 37177.53 ns 49651.90 ns 50906.47 ns 0.98

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1114.00 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 852.60 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1000.98 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 838.41 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+first()+subscribe 1235.89 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+last()+subscribe 947.11 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1177.56 ns 17.90 ns 18.22 ns 0.98

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 262.57 ns 2.16 ns 2.16 ns 1.00
current_thread scheduler create worker + schedule 415.15 ns 5.56 ns 5.56 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 815.79 ns 56.78 ns 56.47 ns 1.01

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 874.19 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 939.18 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2347.29 ns 190.54 ns 156.73 ns 1.22
immediate_just+buffer(2)+subscribe 1555.64 ns 13.58 ns 13.89 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 2444.40 ns 1163.83 ns 1080.35 ns 1.08

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 859.40 ns - - 0.00
immediate_just+take_while(true)+subscribe 883.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 2055.75 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 3427.19 ns 179.36 ns 185.41 ns 0.97
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3724.98 ns 175.49 ns 183.55 ns 0.96
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 134.09 ns 145.20 ns 0.92
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3571.38 ns 1015.74 ns 1130.97 ns 0.90
immediate_just(1) + zip(immediate_just(2)) + subscribe 2089.90 ns 203.10 ns 203.86 ns 1.00

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 34.58 ns 16.86 ns 16.79 ns 1.00

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1329.39 ns 13.58 ns 13.59 ns 1.00
basic sample with immediate scheduler 1336.76 ns 5.55 ns 5.55 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 973.41 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 1105.66 ns 118.43 ns 120.92 ns 0.98

ci-macos

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 979.31 ns 3.96 ns 3.95 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 979.77 ns 3.90 ns 3.85 ns 1.01

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1940.00 ns 0.23 ns 0.23 ns 1.00
from array of 1 - create + subscribe + current_thread 2449.73 ns 34.50 ns 34.83 ns 0.99
concat_as_source of just(1 immediate) create + subscribe 5430.97 ns 335.64 ns 335.80 ns 1.00
defer from array of 1 - defer + create + subscribe + immediate 1966.20 ns 0.23 ns 0.24 ns 0.99
interval - interval + take(3) + subscribe + immediate 4937.39 ns 114.70 ns 114.58 ns 1.00
interval - interval + take(3) + subscribe + current_thread 6010.68 ns 95.32 ns 95.76 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 83012.31 ns 82884.79 ns 82825.43 ns 1.00
from array of 1000 - create + as_blocking + subscribe + new_thread 87773.33 ns 85587.36 ns 94584.50 ns 0.90

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 2841.71 ns 0.23 ns 0.23 ns 1.00
immediate_just+filter(true)+subscribe 2114.39 ns 0.23 ns 0.23 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 2763.75 ns 0.23 ns 0.23 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 2080.31 ns 0.47 ns 0.47 ns 1.00
immediate_just(1,2)+first()+subscribe 3179.39 ns 0.23 ns 0.23 ns 1.00
immediate_just(1,2)+last()+subscribe 2386.78 ns 0.23 ns 0.23 ns 1.00
immediate_just+take_last(1)+subscribe 3030.74 ns 69.07 ns 71.51 ns 0.97

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 848.68 ns 4.12 ns 4.14 ns 1.00
current_thread scheduler create worker + schedule 1187.26 ns 39.48 ns 39.20 ns 1.01
current_thread scheduler create worker + schedule + recursive schedule 2010.92 ns 205.37 ns 203.01 ns 1.01

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 2464.76 ns 0.23 ns 0.23 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 2343.28 ns 0.47 ns 0.47 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 5349.44 ns 403.80 ns 399.39 ns 1.01
immediate_just+buffer(2)+subscribe 2525.70 ns 69.06 ns 71.43 ns 0.97
immediate_just+window(2)+subscribe + subscsribe inner 5472.52 ns 2324.57 ns 2277.93 ns 1.02

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 2092.38 ns - - 0.00
immediate_just+take_while(true)+subscribe 2111.44 ns 0.23 ns 0.23 ns 1.00

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 4921.95 ns 0.23 ns 0.23 ns 1.00

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 7368.92 ns 435.32 ns 437.08 ns 1.00
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 8380.04 ns 441.23 ns 441.34 ns 1.00
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 463.46 ns 475.14 ns 0.98
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 7927.81 ns 1910.59 ns 1919.79 ns 1.00
immediate_just(1) + zip(immediate_just(2)) + subscribe 5143.60 ns 848.97 ns 846.34 ns 1.00

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 74.73 ns 50.39 ns 49.25 ns 1.02

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 2769.19 ns 70.23 ns 70.54 ns 1.00
basic sample with immediate scheduler 2775.27 ns 14.34 ns 13.99 ns 1.02

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 2382.02 ns 0.23 ns 0.23 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 6514.49 ns 4036.88 ns 4061.20 ns 0.99

ci-ubuntu-clang

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 269.63 ns 0.88 ns 0.88 ns 1.01
Subscribe empty callbacks to empty observable via pipe operator 280.57 ns 0.88 ns 0.88 ns 1.00

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 571.08 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 794.75 ns 4.01 ns 4.01 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2355.44 ns 136.27 ns 135.34 ns 1.01
defer from array of 1 - defer + create + subscribe + immediate 775.08 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2221.93 ns 58.37 ns 58.31 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3191.42 ns 30.86 ns 30.88 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 29121.89 ns 27487.55 ns 28083.17 ns 0.98
from array of 1000 - create + as_blocking + subscribe + new_thread 35437.11 ns 33638.65 ns 35967.78 ns 0.94

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1165.90 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 856.44 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1092.75 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 885.23 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+first()+subscribe 1362.67 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+last()+subscribe 1024.24 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1192.11 ns 0.31 ns 0.31 ns 1.00

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 278.75 ns 0.88 ns 0.88 ns 1.00
current_thread scheduler create worker + schedule 394.21 ns 4.63 ns 4.63 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 845.48 ns 56.40 ns 56.82 ns 0.99

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 858.24 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 993.79 ns 0.62 ns 0.62 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2278.30 ns 140.17 ns 137.42 ns 1.02
immediate_just+buffer(2)+subscribe 1517.11 ns 13.58 ns 13.90 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 2446.97 ns 901.48 ns 910.14 ns 0.99

Conditional Operators

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

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1990.64 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 3240.82 ns 161.18 ns 159.53 ns 1.01
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3739.61 ns 147.54 ns 145.96 ns 1.01
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 142.87 ns 142.29 ns 1.00
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3401.54 ns 842.51 ns 859.84 ns 0.98
immediate_just(1) + zip(immediate_just(2)) + subscribe 2232.04 ns 204.24 ns 208.74 ns 0.98

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 52.18 ns 18.14 ns 18.57 ns 0.98

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1290.73 ns 12.03 ns 12.04 ns 1.00
basic sample with immediate scheduler 1296.81 ns 5.86 ns 5.86 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 1004.18 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 1091.89 ns 136.34 ns 136.65 ns 1.00

ci-windows

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 570.49 ns 4.76 ns 4.01 ns 1.19
Subscribe empty callbacks to empty observable via pipe operator 584.87 ns 4.74 ns 4.01 ns 1.18

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1168.83 ns 4.93 ns 4.93 ns 1.00
from array of 1 - create + subscribe + current_thread 1433.77 ns 15.74 ns 15.74 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 3984.33 ns 176.13 ns 170.18 ns 1.03
defer from array of 1 - defer + create + subscribe + immediate 1460.78 ns 4.93 ns 4.93 ns 1.00
interval - interval + take(3) + subscribe + immediate 2943.63 ns 133.99 ns 133.66 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3457.91 ns 52.75 ns 52.56 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 123437.50 ns 115080.00 ns 114880.00 ns 1.00
from array of 1000 - create + as_blocking + subscribe + new_thread 132744.44 ns 131271.43 ns 133833.33 ns 0.98

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1888.54 ns 12.86 ns 12.86 ns 1.00
immediate_just+filter(true)+subscribe 1622.94 ns 12.37 ns 11.71 ns 1.06
immediate_just(1,2)+skip(1)+subscribe 2042.68 ns 13.04 ns 13.00 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 1372.63 ns 15.95 ns 15.81 ns 1.01
immediate_just(1,2)+first()+subscribe 2111.50 ns 12.96 ns 12.63 ns 1.03
immediate_just(1,2)+last()+subscribe 1485.71 ns 13.79 ns 14.09 ns 0.98
immediate_just+take_last(1)+subscribe 2096.93 ns 57.67 ns 61.14 ns 0.94

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 490.27 ns 17.21 ns 6.48 ns 2.66
current_thread scheduler create worker + schedule 669.02 ns 22.22 ns 13.08 ns 1.70
current_thread scheduler create worker + schedule + recursive schedule 1316.99 ns 103.75 ns 103.19 ns 1.01

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 1346.05 ns 12.26 ns 11.11 ns 1.10
immediate_just+scan(10, std::plus)+subscribe 1453.98 ns 21.59 ns 21.27 ns 1.01
immediate_just+flat_map(immediate_just(v*2))+subscribe 3860.79 ns 219.76 ns 222.18 ns 0.99
immediate_just+buffer(2)+subscribe 2567.34 ns 62.64 ns 64.47 ns 0.97
immediate_just+window(2)+subscribe + subscsribe inner 4060.82 ns 1228.23 ns 1213.70 ns 1.01

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 1412.16 ns 11.45 ns 11.45 ns 1.00
immediate_just+take_while(true)+subscribe 1347.18 ns 12.37 ns 11.72 ns 1.06

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 3534.68 ns 7.09 ns 7.09 ns 1.00

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 5593.43 ns 231.45 ns 249.23 ns 0.93
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 6476.84 ns 221.37 ns 225.02 ns 0.98
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 237.30 ns 231.12 ns 1.03
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 5491.98 ns 952.52 ns 950.19 ns 1.00
immediate_just(1) + zip(immediate_just(2)) + subscribe 3836.97 ns 538.60 ns 532.19 ns 1.01

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 37.32 ns 25.59 ns 26.84 ns 0.95

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1888.76 ns 57.83 ns 58.41 ns 0.99
basic sample with immediate scheduler 1906.32 ns 36.72 ns 36.75 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 1470.55 ns 19.94 ns 19.95 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.04 ns 342.31 ns 332.61 ns 1.03

Copy link

sonarcloud bot commented May 27, 2024

Quality Gate Passed Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
No data about Coverage
No data about Duplication

See analysis details on SonarCloud

@victimsnino victimsnino merged commit 4f01203 into v2 May 28, 2024
35 checks passed
@victimsnino victimsnino deleted the move_presets branch May 28, 2024 05:10
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.

None yet

1 participant