Skip to content

Commit

Permalink
Update comment_benchmarks_v2.yml
Browse files Browse the repository at this point in the history
  • Loading branch information
@victimsnino
victimsnino authored Nov 22, 2024
1 parent b9250c8 commit 86b6bbb
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions .github/workflows/comment_benchmarks_v2.yml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,8 @@ jobs:
with:
token: ${{ secrets.GITHUB_TOKEN }}
fetch-depth: 0
repository: ${{ github.event.workflow_run.head_repository.full_name }}
ref: ${{ github.event.workflow_run.head_branch }}

- name: Download all workflow run artifacts
uses: dawidd6/action-download-artifact@v6
Expand Down

1 comment on commit 86b6bbb

@github-actions
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

BENCHMARK RESULTS (AUTOGENERATED)

ci-ubuntu-gcc

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 307.75 ns 1.88 ns 1.54 ns 1.21
Subscribe empty callbacks to empty observable via pipe operator 304.59 ns 1.85 ns 1.54 ns 1.20

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 691.47 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 1045.31 ns 3.43 ns 3.43 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2248.81 ns 111.42 ns 112.21 ns 0.99
defer from array of 1 - defer + create + subscribe + immediate 730.18 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2141.65 ns 59.29 ns 60.16 ns 0.99
interval - interval + take(3) + subscribe + current_thread 3036.12 ns 32.46 ns 32.44 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 29551.26 ns 27946.12 ns 28033.29 ns 1.00
from array of 1000 - create + as_blocking + subscribe + new_thread 39513.07 ns 52624.58 ns 51971.09 ns 1.01
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 3434.05 ns 139.50 ns 132.21 ns 1.06

Filtering Operators
name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1080.95 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 852.46 ns 0.31 ns 0.31 ns 0.99
immediate_just(1,2)+skip(1)+subscribe 984.65 ns 0.31 ns 0.54 ns 0.57
immediate_just(1,1,2)+distinct_until_changed()+subscribe 846.51 ns 0.31 ns 0.55 ns 0.56
immediate_just(1,2)+first()+subscribe 1242.50 ns 0.31 ns 0.54 ns 0.57
immediate_just(1,2)+last()+subscribe 906.26 ns 0.31 ns 0.56 ns 0.55
immediate_just+take_last(1)+subscribe 1118.09 ns 18.22 ns 18.23 ns 1.00
immediate_just(1,2,3)+element_at(1)+subscribe 834.71 ns 0.31 ns 0.31 ns 0.98

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 266.64 ns 1.54 ns 0.62 ns 2.50
current_thread scheduler create worker + schedule 370.95 ns 4.63 ns 4.63 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 830.27 ns 60.91 ns 60.53 ns 1.01

Transforming Operators
name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 885.90 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 897.37 ns 0.31 ns 0.31 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2349.27 ns 150.16 ns 143.13 ns 1.05
immediate_just+buffer(2)+subscribe 1524.34 ns 13.90 ns 13.89 ns 1.00
immediate_just+window(2)+subscribe + subscsribe inner 2361.03 ns 1336.72 ns 1303.28 ns 1.03

Conditional Operators
name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 846.43 ns - - 0.00
immediate_just+take_while(true)+subscribe 845.85 ns 0.31 ns 0.31 ns 1.00

Utility Operators
name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1983.61 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 3467.86 ns 170.11 ns 167.76 ns 1.01
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3684.03 ns 162.91 ns 162.65 ns 1.00
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 147.43 ns 133.77 ns 1.10
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3601.80 ns 373.29 ns 369.28 ns 1.01
immediate_just(1) + zip(immediate_just(2)) + subscribe 2108.22 ns 213.98 ns 211.23 ns 1.01
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe 3136.33 ns 222.74 ns 225.47 ns 0.99

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 34.56 ns 14.67 ns 14.68 ns 1.00
subscribe 100 observers to publish_subject 200662.60 ns 16476.81 ns 16209.13 ns 1.02
100 on_next to 100 observers to publish_subject 28476.78 ns 20131.38 ns 17243.54 ns 1.17

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 1342.13 ns 12.97 ns 12.96 ns 1.00
basic sample with immediate scheduler 1351.82 ns 5.55 ns 5.55 ns 1.00

Aggregating Operators
name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 922.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 2054.56 ns 996.03 ns 991.58 ns 1.00
create(on_error())+retry(1)+subscribe 594.01 ns 112.56 ns 109.56 ns 1.03

ci-macos

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 997.17 ns 0.47 ns 0.47 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 1165.13 ns 0.51 ns 0.46 ns 1.12

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2303.77 ns 0.27 ns 0.23 ns 1.19
from array of 1 - create + subscribe + current_thread 2465.72 ns 33.75 ns 32.56 ns 1.04
concat_as_source of just(1 immediate) create + subscribe 5957.30 ns 316.80 ns 314.23 ns 1.01
defer from array of 1 - defer + create + subscribe + immediate 1999.66 ns 0.23 ns 0.23 ns 1.00
interval - interval + take(3) + subscribe + immediate 4963.71 ns 114.07 ns 113.09 ns 1.01
interval - interval + take(3) + subscribe + current_thread 6539.88 ns 98.59 ns 97.58 ns 1.01
from array of 1 - create + as_blocking + subscribe + new_thread 86993.25 ns 82186.92 ns 80924.08 ns 1.02
from array of 1000 - create + as_blocking + subscribe + new_thread 95957.27 ns 92108.75 ns 86662.15 ns 1.06
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 8468.17 ns 360.00 ns 358.62 ns 1.00

Filtering Operators
name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 2897.45 ns 0.23 ns 0.23 ns 1.00
immediate_just+filter(true)+subscribe 2123.93 ns 0.23 ns 0.23 ns 1.01
immediate_just(1,2)+skip(1)+subscribe 2758.27 ns 0.23 ns 0.23 ns 1.02
immediate_just(1,1,2)+distinct_until_changed()+subscribe 2081.17 ns 0.47 ns 0.46 ns 1.02
immediate_just(1,2)+first()+subscribe 3227.64 ns 0.24 ns 0.23 ns 1.01
immediate_just(1,2)+last()+subscribe 2391.18 ns 0.23 ns 0.23 ns 1.03
immediate_just+take_last(1)+subscribe 3048.60 ns 0.24 ns 0.23 ns 1.01
immediate_just(1,2,3)+element_at(1)+subscribe 2606.01 ns 0.23 ns 0.23 ns 1.03

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 937.72 ns 1.05 ns 0.93 ns 1.12
current_thread scheduler create worker + schedule 1240.23 ns 35.30 ns 33.92 ns 1.04
current_thread scheduler create worker + schedule + recursive schedule 2053.89 ns 201.32 ns 197.34 ns 1.02

Transforming Operators
name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 2103.96 ns 4.20 ns 4.10 ns 1.03
immediate_just+scan(10, std::plus)+subscribe 2331.98 ns 0.47 ns 0.46 ns 1.03
immediate_just+flat_map(immediate_just(v*2))+subscribe 5341.12 ns 412.75 ns 376.66 ns 1.10
immediate_just+buffer(2)+subscribe 2499.92 ns 63.18 ns 63.90 ns 0.99
immediate_just+window(2)+subscribe + subscsribe inner 5407.87 ns 2363.55 ns 2282.67 ns 1.04

Conditional Operators
name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 2123.49 ns - - 0.00
immediate_just+take_while(true)+subscribe 2109.28 ns 0.24 ns 0.23 ns 1.07

Utility Operators
name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 4913.34 ns 4.90 ns 4.78 ns 1.02

Combining Operators
name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 7520.52 ns 415.72 ns 402.87 ns 1.03
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 8514.67 ns 408.99 ns 396.99 ns 1.03
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 451.67 ns 436.10 ns 1.04
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 7889.16 ns 981.13 ns 890.74 ns 1.10
immediate_just(1) + zip(immediate_just(2)) + subscribe 10633.75 ns 829.58 ns 808.70 ns 1.03
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe 7443.55 ns 640.48 ns 624.44 ns 1.03

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 73.95 ns 50.87 ns 49.93 ns 1.02
subscribe 100 observers to publish_subject 354643.00 ns 40750.29 ns 40742.11 ns 1.00
100 on_next to 100 observers to publish_subject 53481.37 ns 20991.56 ns 30058.31 ns 0.70

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 2764.80 ns 71.82 ns 72.49 ns 0.99
basic sample with immediate scheduler 2752.15 ns 18.81 ns 18.80 ns 1.00

Aggregating Operators
name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 2403.05 ns 0.23 ns 0.23 ns 1.03

Error Handling Operators
name rxcpp rpp prev rpp ratio
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe 6656.70 ns 4065.71 ns 3955.54 ns 1.03
create(on_error())+retry(1)+subscribe 1870.60 ns 277.38 ns 283.56 ns 0.98

ci-ubuntu-clang

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 269.12 ns 1.55 ns 1.54 ns 1.01
Subscribe empty callbacks to empty observable via pipe operator 270.89 ns 1.55 ns 1.54 ns 1.00

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 572.29 ns 0.31 ns 0.31 ns 1.00
from array of 1 - create + subscribe + current_thread 791.26 ns 4.01 ns 4.01 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2347.45 ns 129.93 ns 130.00 ns 1.00
defer from array of 1 - defer + create + subscribe + immediate 787.62 ns 0.31 ns 0.31 ns 1.00
interval - interval + take(3) + subscribe + immediate 2231.55 ns 58.36 ns 58.26 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3179.87 ns 30.92 ns 30.88 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 30493.14 ns 28683.55 ns 28030.64 ns 1.02
from array of 1000 - create + as_blocking + subscribe + new_thread 38731.32 ns 37552.96 ns 34927.91 ns 1.08
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 3651.50 ns 148.79 ns 148.75 ns 1.00

Filtering Operators
name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1138.72 ns 0.31 ns 0.31 ns 1.00
immediate_just+filter(true)+subscribe 841.61 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1076.89 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 868.64 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+first()+subscribe 1352.52 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2)+last()+subscribe 995.15 ns 0.31 ns 0.31 ns 1.00
immediate_just+take_last(1)+subscribe 1172.52 ns 0.31 ns 0.31 ns 1.00
immediate_just(1,2,3)+element_at(1)+subscribe 859.83 ns 0.31 ns 0.31 ns 1.00

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 280.41 ns 0.63 ns 0.63 ns 1.00
current_thread scheduler create worker + schedule 385.83 ns 4.33 ns 4.01 ns 1.08
current_thread scheduler create worker + schedule + recursive schedule 854.18 ns 55.46 ns 57.70 ns 0.96

Transforming Operators
name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 839.50 ns 0.31 ns 0.31 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 953.61 ns 0.62 ns 0.62 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 2223.05 ns 139.19 ns 136.04 ns 1.02
immediate_just+buffer(2)+subscribe 1545.82 ns 14.22 ns 14.51 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 2422.98 ns 912.57 ns 927.94 ns 0.98

Conditional Operators
name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 828.19 ns - - 0.00
immediate_just+take_while(true)+subscribe 835.11 ns 0.31 ns 0.31 ns 1.00

Utility Operators
name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 1952.06 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 3336.87 ns 159.54 ns 157.42 ns 1.01
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 3717.54 ns 139.39 ns 137.30 ns 1.02
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 140.79 ns 142.79 ns 0.99
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 3380.02 ns 377.65 ns 377.35 ns 1.00
immediate_just(1) + zip(immediate_just(2)) + subscribe 2192.30 ns 207.50 ns 209.98 ns 0.99
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe 3237.06 ns 220.65 ns 219.87 ns 1.00

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 54.00 ns 17.23 ns 17.58 ns 0.98
subscribe 100 observers to publish_subject 211026.00 ns 16020.47 ns 15994.85 ns 1.00
100 on_next to 100 observers to publish_subject 35372.24 ns 20588.27 ns 20588.25 ns 1.00

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 1308.01 ns 10.80 ns 10.81 ns 1.00
basic sample with immediate scheduler 1298.26 ns 6.18 ns 6.17 ns 1.00

Aggregating Operators
name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 994.19 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 2171.85 ns 1205.94 ns 1156.27 ns 1.04
create(on_error())+retry(1)+subscribe 651.44 ns 138.23 ns 138.43 ns 1.00

ci-windows

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 563.25 ns 2.16 ns 2.16 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 578.54 ns 2.16 ns 2.16 ns 1.00

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1151.62 ns 5.24 ns 5.24 ns 1.00
from array of 1 - create + subscribe + current_thread 1425.70 ns 15.44 ns 15.44 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 3747.71 ns 173.89 ns 175.78 ns 0.99
defer from array of 1 - defer + create + subscribe + immediate 1198.23 ns 5.24 ns 5.24 ns 1.00
interval - interval + take(3) + subscribe + immediate 3366.77 ns 139.49 ns 139.82 ns 1.00
interval - interval + take(3) + subscribe + current_thread 3450.60 ns 59.85 ns 59.97 ns 1.00
from array of 1 - create + as_blocking + subscribe + new_thread 119040.00 ns 116188.89 ns 108970.00 ns 1.07
from array of 1000 - create + as_blocking + subscribe + new_thread 129888.89 ns 131055.56 ns 127837.50 ns 1.03
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe 5348.58 ns 202.41 ns 216.85 ns 0.93

Filtering Operators
name rxcpp rpp prev rpp ratio
immediate_just+take(1)+subscribe 1836.54 ns 19.43 ns 19.42 ns 1.00
immediate_just+filter(true)+subscribe 1631.81 ns 18.50 ns 18.50 ns 1.00
immediate_just(1,2)+skip(1)+subscribe 1716.33 ns 17.89 ns 17.89 ns 1.00
immediate_just(1,1,2)+distinct_until_changed()+subscribe 1351.58 ns 20.67 ns 20.67 ns 1.00
immediate_just(1,2)+first()+subscribe 2359.95 ns 18.21 ns 18.21 ns 1.00
immediate_just(1,2)+last()+subscribe 1925.00 ns 23.60 ns 19.14 ns 1.23
immediate_just+take_last(1)+subscribe 2026.93 ns 68.53 ns 68.81 ns 1.00
immediate_just(1,2,3)+element_at(1)+subscribe 1623.93 ns 20.99 ns 21.17 ns 0.99

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 474.65 ns 4.32 ns 4.32 ns 1.00
current_thread scheduler create worker + schedule 651.61 ns 12.02 ns 12.02 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 1329.91 ns 96.62 ns 99.90 ns 0.97

Transforming Operators
name rxcpp rpp prev rpp ratio
immediate_just+map(v*2)+subscribe 1329.32 ns 18.81 ns 18.82 ns 1.00
immediate_just+scan(10, std::plus)+subscribe 1427.23 ns 20.98 ns 20.96 ns 1.00
immediate_just+flat_map(immediate_just(v*2))+subscribe 3847.47 ns 192.88 ns 188.03 ns 1.03
immediate_just+buffer(2)+subscribe 2316.89 ns 63.03 ns 64.19 ns 0.98
immediate_just+window(2)+subscribe + subscsribe inner 4029.64 ns 1290.11 ns 1287.52 ns 1.00

Conditional Operators
name rxcpp rpp prev rpp ratio
immediate_just+take_while(false)+subscribe 1311.67 ns 17.57 ns 17.57 ns 1.00
immediate_just+take_while(true)+subscribe 1317.92 ns 18.50 ns 18.50 ns 1.00

Utility Operators
name rxcpp rpp prev rpp ratio
immediate_just(1)+subscribe_on(immediate)+subscribe 3234.00 ns 11.11 ns 11.11 ns 1.00

Combining Operators
name rxcpp rpp prev rpp ratio
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe 5145.00 ns 219.07 ns 210.12 ns 1.04
immediate_just(1) + merge_with(immediate_just(2)) + subscribe 5749.46 ns 183.52 ns 188.40 ns 0.97
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe - 192.39 ns 195.12 ns 0.99
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe 6156.70 ns 470.79 ns 449.56 ns 1.05
immediate_just(1) + zip(immediate_just(2)) + subscribe 3860.29 ns 548.15 ns 527.27 ns 1.04
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe 4918.80 ns 337.87 ns 330.33 ns 1.02

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 36.03 ns 20.72 ns 20.36 ns 1.02
subscribe 100 observers to publish_subject 248120.00 ns 28275.61 ns 27946.34 ns 1.01
100 on_next to 100 observers to publish_subject 51900.00 ns 35700.00 ns 36077.42 ns 0.99

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 1867.30 ns 96.84 ns 96.78 ns 1.00
basic sample with immediate scheduler 1889.60 ns 66.70 ns 67.32 ns 0.99

Aggregating Operators
name rxcpp rpp prev rpp ratio
immediate_just+reduce(10, std::plus)+subscribe 1463.49 ns 19.13 ns 19.11 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 1940.94 ns 355.66 ns 361.63 ns 0.98
create(on_error())+retry(1)+subscribe 1577.02 ns 138.60 ns 138.61 ns 1.00

Please sign in to comment.