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

try to debug #600

Closed
wants to merge 2 commits into from
Closed

try to debug #600

wants to merge 2 commits into from

Conversation

victimsnino
Copy link
Owner

No description provided.

Copy link
Contributor

BENCHMARK RESULTS (AUTOGENERATED)

ci-ubuntu-gcc

General

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

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 697.08 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 1048.83 ns 3.70 ns 3.70 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2238.71 ns 119.58 ns 120.01 ns 1.00
defer from array of 1 - defer + create + subscribe + immediate 731.41 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2189.22 ns 59.27 ns 59.24 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3047.01 ns 32.42 ns 32.40 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 31898.19 ns 27871.10 ns 27377.71 ns 1.02
from array of 1000 - create + as_blocking + subscribe + new_thread 39735.05 ns 49192.74 ns 50808.87 ns 0.97
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 3555.50 ns 146.12 ns 148.02 ns 0.99

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1088.83 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 848.12 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 993.68 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 869.86 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+first()+subscribe 1247.86 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+last()+subscribe 907.44 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1163.99 ns 17.90 ns 18.22 ns 0.98

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 264.06 ns 2.16 ns 2.16 ns 1.00
current_thread scheduler create worker + schedule 366.99 ns 5.87 ns 5.86 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 842.72 ns 55.63 ns 55.57 ns 1.00

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 850.05 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 890.38 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2389.67 ns 160.45 ns 171.19 ns 0.94
immediate_just+buffer(2)+subscribe 1521.02 ns 13.58 ns 13.89 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 2365.18 ns 1114.00 ns 1028.99 ns 1.08

Conditional Operators

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

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1989.16 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 3406.95 ns 176.11 ns 182.17 ns 0.97
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3629.88 ns 189.37 ns 178.82 ns 1.06
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 152.22 ns 129.60 ns 1.17
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3532.84 ns 1019.41 ns 942.41 ns 1.08
immediate_just(1) + zip(immediate_just(2)) + subscribe 2081.02 ns 198.32 ns 230.83 ns 0.86

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 34.59 ns 14.64 ns 14.86 ns 0.99
subscribe 100 observers to publish_subject 200167.60 ns 15173.61 ns 52053.20 ns 0.29
100 on_next to 100 observers to publish_subject 27783.97 ns 17078.37 ns 28711.69 ns 0.59

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1393.71 ns 13.27 ns 13.27 ns 1.00
basic sample with immediate scheduler 1369.72 ns 5.55 ns 5.55 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 899.17 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 2064.74 ns 995.37 ns 978.84 ns 1.02

ci-macos

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1197.42 ns 4.89 ns 4.34 ns 1.13
Subscribe empty callbacks to empty observable via pipe operator 1213.11 ns 4.81 ns 3.89 ns 1.24

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2379.03 ns 0.29 ns 0.23 ns 1.23
from array of 1 - create + subscribe + current_thread 3040.90 ns 42.69 ns 32.70 ns 1.31
concat_as_source of just(1 immediate) create + subscribe 6636.43 ns 411.51 ns 336.27 ns 1.22
defer from array of 1 - defer + create + subscribe + immediate 2413.13 ns 0.29 ns 0.23 ns 1.23
interval - interval + take(3) + subscribe + immediate 6083.80 ns 140.78 ns 115.06 ns 1.22
interval - interval + take(3) + subscribe + current_thread 7404.93 ns 120.78 ns 96.91 ns 1.25
from array of 1 - create + as_blocking + subscribe + new_thread 104584.20 ns 107418.86 ns 77282.14 ns 1.39
from array of 1000 - create + as_blocking + subscribe + new_thread 106803.90 ns 110141.22 ns 83798.43 ns 1.31
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 10049.75 ns 472.07 ns 378.05 ns 1.25

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 3520.85 ns 0.29 ns 0.22 ns 1.29
immediate_just+filter(true)+subscribe 2598.22 ns 0.29 ns 0.22 ns 1.29
immediate_just(1,2)+skip(1)+subscribe 3367.13 ns 0.30 ns 0.22 ns 1.35
immediate_just(1,1,2)+distinct_until_changed()+subscribe 2552.79 ns 0.57 ns 0.45 ns 1.29
immediate_just(1,2)+first()+subscribe 3904.18 ns 0.29 ns 0.22 ns 1.29
immediate_just(1,2)+last()+subscribe 3449.80 ns 0.29 ns 0.22 ns 1.29
immediate_just+take_last(1)+subscribe 3738.22 ns 88.61 ns 68.61 ns 1.29

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 1046.42 ns 5.31 ns 4.18 ns 1.27
current_thread scheduler create worker + schedule 1468.37 ns 50.92 ns 37.01 ns 1.38
current_thread scheduler create worker + schedule + recursive schedule 2451.38 ns 252.33 ns 207.30 ns 1.22

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 2591.24 ns 5.16 ns 4.20 ns 1.23
immediate_just+scan(10, std::plus)+subscribe 2881.92 ns 0.57 ns 0.45 ns 1.29
immediate_just+flat_map(immediate_just(v*2))+subscribe 6505.32 ns 494.66 ns 383.66 ns 1.29
immediate_just+buffer(2)+subscribe 3052.92 ns 85.65 ns 66.84 ns 1.28
immediate_just+window(2)+subscribe + subscsribe inner 6584.86 ns 3032.48 ns 2220.63 ns 1.37

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 2628.35 ns - - 0.00
immediate_just+take_while(true)+subscribe 2614.12 ns 0.29 ns 0.23 ns 1.24

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 6127.38 ns 6.05 ns 5.51 ns 1.10

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 9203.52 ns 539.58 ns 441.71 ns 1.22
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 10481.55 ns 682.29 ns 439.54 ns 1.55
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 708.91 ns 459.85 ns 1.54
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 9804.80 ns 2370.56 ns 1920.23 ns 1.23
immediate_just(1) + zip(immediate_just(2)) + subscribe 6274.82 ns 1035.37 ns 851.59 ns 1.22

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 90.41 ns 60.24 ns 49.27 ns 1.22
subscribe 100 observers to publish_subject 433738.00 ns 50329.76 ns 124131.75 ns 0.41
100 on_next to 100 observers to publish_subject 64474.75 ns 20897.93 ns 29554.13 ns 0.71

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 3298.25 ns 80.13 ns 68.90 ns 1.16
basic sample with immediate scheduler 3309.97 ns 23.01 ns 18.65 ns 1.23

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 2945.84 ns 0.29 ns 0.23 ns 1.23

Error Handling Operators

name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 7962.12 ns 4994.27 ns 4078.33 ns 1.22

ci-ubuntu-clang

General

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

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 564.53 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 788.67 ns 4.01 ns 4.01 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2431.53 ns 141.89 ns 137.78 ns 1.03
defer from array of 1 - defer + create + subscribe + immediate 780.89 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2227.50 ns 58.36 ns 58.34 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3234.76 ns 30.88 ns 30.88 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 29829.50 ns 27672.30 ns 28788.03 ns 0.96
from array of 1000 - create + as_blocking + subscribe + new_thread 38831.96 ns 35056.59 ns 34170.36 ns 1.03
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 3740.40 ns 158.73 ns 162.85 ns 0.97

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1191.31 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 845.47 ns 0.31 ns 0.39 ns 0.79
immediate_just(1,2)+skip(1)+subscribe 1109.69 ns 0.31 ns 0.31 ns 0.99
immediate_just(1,1,2)+distinct_until_changed()+subscribe 873.43 ns 0.31 ns 0.62 ns 0.50
immediate_just(1,2)+first()+subscribe 1406.77 ns 0.31 ns 0.33 ns 0.94
immediate_just(1,2)+last()+subscribe 1007.64 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1247.79 ns 0.31 ns 0.31 ns 1.00

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 282.41 ns 0.88 ns 0.88 ns 1.00
current_thread scheduler create worker + schedule 392.01 ns 4.32 ns 4.02 ns 1.08
current_thread scheduler create worker + schedule + recursive schedule 868.14 ns 55.10 ns 57.29 ns 0.96

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 847.31 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 986.11 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2250.72 ns 137.18 ns 139.37 ns 0.98
immediate_just+buffer(2)+subscribe 1545.60 ns 14.51 ns 13.88 ns 1.05
immediate_just+window(2)+subscribe + subscsribe inner 2465.43 ns 964.22 ns 907.82 ns 1.06

Conditional Operators

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

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1987.17 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 3331.82 ns 163.57 ns 160.35 ns 1.02
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3837.08 ns 148.18 ns 146.17 ns 1.01
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 143.09 ns 142.26 ns 1.01
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3576.35 ns 842.99 ns 843.52 ns 1.00
immediate_just(1) + zip(immediate_just(2)) + subscribe 2318.66 ns 202.79 ns 203.80 ns 1.00

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 52.86 ns 17.90 ns 19.25 ns 0.93
subscribe 100 observers to publish_subject 206856.00 ns 16083.27 ns 49897.33 ns 0.32
100 on_next to 100 observers to publish_subject 38163.17 ns 20617.10 ns 32123.34 ns 0.64

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1305.78 ns 11.42 ns 11.12 ns 1.03
basic sample with immediate scheduler 1315.44 ns 6.17 ns 6.17 ns 1.00

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 990.14 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 2205.62 ns 1216.95 ns 1235.77 ns 0.98

ci-windows

General

name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 557.44 ns 4.94 ns 4.01 ns 1.23
Subscribe empty callbacks to empty observable via pipe operator 576.64 ns 4.94 ns 4.01 ns 1.23

Sources

name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1141.15 ns 5.86 ns 4.62 ns 1.27
from array of 1 - create + subscribe + current_thread 1505.78 ns 16.15 ns 15.74 ns 1.03
concat_as_source of just(1 immediate) create + subscribe 3758.03 ns 177.13 ns 173.49 ns 1.02
defer from array of 1 - defer + create + subscribe + immediate 1187.31 ns 5.86 ns 4.93 ns 1.19
interval - interval + take(3) + subscribe + immediate 3348.52 ns 133.39 ns 133.47 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3377.15 ns 53.94 ns 52.61 ns 1.03
from array of 1 - create + as_blocking + subscribe + new_thread 119930.00 ns 117750.00 ns 110733.33 ns 1.06
from array of 1000 - create + as_blocking + subscribe + new_thread 127755.56 ns 130600.00 ns 130025.00 ns 1.00
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 5306.13 ns 205.14 ns 202.01 ns 1.02

Filtering Operators

name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1823.90 ns 12.87 ns 12.87 ns 1.00
immediate_just+filter(true)+subscribe 1295.85 ns 12.36 ns 11.75 ns 1.05
immediate_just(1,2)+skip(1)+subscribe 1700.67 ns 13.02 ns 13.12 ns 0.99
immediate_just(1,1,2)+distinct_until_changed()+subscribe 1339.80 ns 15.96 ns 15.77 ns 1.01
immediate_just(1,2)+first()+subscribe 2065.46 ns 12.95 ns 12.64 ns 1.03
immediate_just(1,2)+last()+subscribe 1775.47 ns 13.79 ns 14.13 ns 0.98
immediate_just+take_last(1)+subscribe 2023.51 ns 59.26 ns 63.56 ns 0.93

Schedulers

name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 477.90 ns 6.17 ns 6.17 ns 1.00
current_thread scheduler create worker + schedule 648.09 ns 14.05 ns 13.17 ns 1.07
current_thread scheduler create worker + schedule + recursive schedule 1346.12 ns 106.79 ns 103.79 ns 1.03

Transforming Operators

name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 1304.22 ns 12.33 ns 11.10 ns 1.11
immediate_just+scan(10, std::plus)+subscribe 1425.91 ns 21.58 ns 21.27 ns 1.01
immediate_just+flat_map(immediate_just(v*2))+subscribe 3458.13 ns 199.92 ns 211.09 ns 0.95
immediate_just+buffer(2)+subscribe 2614.55 ns 57.90 ns 58.09 ns 1.00
immediate_just+window(2)+subscribe + subscsribe inner 3992.16 ns 1269.24 ns 1235.98 ns 1.03

Conditional Operators

name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 1595.29 ns 11.41 ns 11.41 ns 1.00
immediate_just+take_while(true)+subscribe 1290.85 ns 12.36 ns 11.74 ns 1.05

Utility Operators

name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 3144.17 ns 8.02 ns 7.09 ns 1.13

Combining Operators

name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 5061.90 ns 209.72 ns 241.41 ns 0.87
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 5428.00 ns 215.02 ns 221.83 ns 0.97
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 195.85 ns 227.00 ns 0.86
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 5385.45 ns 926.40 ns 974.93 ns 0.95
immediate_just(1) + zip(immediate_just(2)) + subscribe 3771.91 ns 525.93 ns 542.30 ns 0.97

Subjects

name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 36.54 ns 20.04 ns 27.44 ns 0.73
subscribe 100 observers to publish_subject 255760.00 ns 29056.10 ns 80550.00 ns 0.36
100 on_next to 100 observers to publish_subject 51995.00 ns 32630.00 ns 63850.00 ns 0.51

Scenarios

name rxcpp rpp prev rpp ratio
basic sample 1874.91 ns 57.00 ns 56.50 ns 1.01
basic sample with immediate scheduler 1879.96 ns 38.25 ns 36.40 ns 1.05

Aggregating Operators

name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 1433.96 ns 19.99 ns 19.97 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 1880.39 ns 335.23 ns 334.07 ns 1.00

Copy link

sonarcloud bot commented Jun 12, 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 marked this pull request as ready for review June 12, 2024 19:46
@victimsnino victimsnino deleted the try_to_debug branch June 12, 2024 19:46
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