Skip to content

Commit

Permalink
One more docs fix
Browse files Browse the repository at this point in the history
  • Loading branch information
@victimsnino
victimsnino committed Aug 1, 2023
1 parent bcd1639 commit 4891cff
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/rpp/rpp/schedulers/immediate.hpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ namespace rpp::schedulers
std::cout << "Task 1 ends" << std::endl;
return rpp::schedulers::optional_duration{};
}, obse
}, observer);
```
*
* Would lead to:
Expand Down

1 comment on commit 4891cff

@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 840.38 ns 1.49 ns 1.85 ns 0.80
Subscribe empty callbacks to empty observable via pipe operator 812.19 ns 1.52 ns 1.74 ns 0.88

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2077.29 ns 0.37 ns 0.80 ns 0.46
from array of 1 - create + subscribe + current_thread 3104.54 ns 45.32 ns 53.42 ns 0.85
concat_as_source of just(1 immediate) create + subscribe 6578.18 ns 0.38 ns 0.40 ns 0.94

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 1699.33 ns 0.40 ns 0.39 ns 1.03
create+filter(true)+subscribe 1022.99 ns 0.42 ns 0.40 ns 1.04
create(1,2)+skip(1)+subscribe 1364.70 ns 0.40 ns 0.40 ns 1.01
create(1,1,2)+distinct_until_changed()+subscribe 977.14 ns 0.40 ns 0.40 ns 0.99
create(1,2)+first()+subscribe 3278.33 ns 0.41 ns 0.40 ns 1.02
create(1,2)+last()+subscribe 1274.00 ns 0.39 ns 0.40 ns 0.96

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 862.15 ns 1.16 ns 1.21 ns 0.96
current_thread scheduler create worker + schedule 993.13 ns 8.50 ns 9.23 ns 0.92
current_thread scheduler create worker + schedule + recursive schedule 2321.74 ns 96.51 ns 101.07 ns 0.95

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 969.11 ns 0.37 ns 0.40 ns 0.93
create+scan(10, std::plus)+subscribe 1137.88 ns 0.37 ns 0.40 ns 0.93
create+flat_map(just(v*2))+subscribe 3748.59 ns 172.32 ns 178.79 ns 0.96

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 1020.16 ns - - 0.00
create+take_while(true)+subscribe 981.57 ns 0.37 ns 0.41 ns 0.90

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 3934.91 ns 38.06 ns 39.47 ns 0.96

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 5084.55 ns 201.28 ns 219.65 ns 0.92
create(1) + merge_with(create(2)) + subscribe 8089.21 ns 197.85 ns 209.60 ns 0.94

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 118.49 ns 91.78 ns 93.93 ns 0.98

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 4729.66 ns 130.89 ns 141.28 ns 0.93

ci-macos

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1103.78 ns 0.56 ns 0.56 ns 0.99
Subscribe empty callbacks to empty observable via pipe operator 1067.94 ns 0.56 ns 0.56 ns 1.00

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2325.68 ns 0.44 ns 0.43 ns 1.01
from array of 1 - create + subscribe + current_thread 2980.00 ns 101.24 ns 95.71 ns 1.06
concat_as_source of just(1 immediate) create + subscribe 6833.24 ns 0.28 ns 0.28 ns 1.00

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 1926.08 ns 3.57 ns 3.69 ns 0.97
create+filter(true)+subscribe 1135.51 ns 2.78 ns 2.75 ns 1.01
create(1,2)+skip(1)+subscribe 1766.15 ns 5.28 ns 5.33 ns 0.99
create(1,1,2)+distinct_until_changed()+subscribe 1162.79 ns 7.82 ns 8.01 ns 0.98
create(1,2)+first()+subscribe 2306.62 ns 5.55 ns 5.64 ns 0.98
create(1,2)+last()+subscribe 1420.60 ns 7.78 ns 7.78 ns 1.00

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 965.54 ns 0.54 ns 0.56 ns 0.97
current_thread scheduler create worker + schedule 1324.24 ns 9.47 ns 9.51 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 2259.45 ns 154.10 ns 178.69 ns 0.86

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 1134.44 ns 2.71 ns 2.78 ns 0.97
create+scan(10, std::plus)+subscribe 1338.01 ns 4.33 ns 4.44 ns 0.97
create+flat_map(just(v*2))+subscribe 3214.34 ns 289.46 ns 307.83 ns 0.94

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 1150.88 ns 3.26 ns 3.35 ns 0.97
create+take_while(true)+subscribe 1100.34 ns 2.43 ns 2.50 ns 0.97

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 3655.45 ns 84.53 ns 86.78 ns 0.97

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 3894.43 ns 322.56 ns 333.42 ns 0.97
create(1) + merge_with(create(2)) + subscribe 6948.30 ns 331.44 ns 343.56 ns 0.96

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 97.74 ns 93.15 ns 91.02 ns 1.02

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 4421.45 ns 240.72 ns 250.99 ns 0.96

ci-ubuntu-clang

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 398.72 ns 1.56 ns 1.12 ns 1.40
Subscribe empty callbacks to empty observable via pipe operator 399.67 ns 1.54 ns 1.19 ns 1.29

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 854.06 ns 0.38 ns 0.39 ns 0.96
from array of 1 - create + subscribe + current_thread 1198.97 ns 30.56 ns 30.55 ns 1.00
concat_as_source of just(1 immediate) create + subscribe 2668.18 ns 0.38 ns 0.38 ns 1.02

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 734.72 ns 0.39 ns 0.38 ns 1.01
create+filter(true)+subscribe 416.97 ns 0.38 ns 0.38 ns 1.02
create(1,2)+skip(1)+subscribe 640.20 ns 0.39 ns 0.37 ns 1.06
create(1,1,2)+distinct_until_changed()+subscribe 450.15 ns 0.78 ns 0.72 ns 1.08
create(1,2)+first()+subscribe 905.90 ns 0.38 ns 0.38 ns 1.00
create(1,2)+last()+subscribe 552.70 ns 0.37 ns 0.38 ns 0.99

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 312.31 ns 1.14 ns 1.49 ns 0.77
current_thread scheduler create worker + schedule 457.88 ns 8.29 ns 7.21 ns 1.15
current_thread scheduler create worker + schedule + recursive schedule 930.55 ns 77.18 ns 75.28 ns 1.03

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 445.68 ns 0.38 ns 0.38 ns 1.02
create+scan(10, std::plus)+subscribe 533.25 ns 0.77 ns 0.73 ns 1.06
create+flat_map(just(v*2))+subscribe 1999.17 ns 90.82 ns 87.48 ns 1.04

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 450.95 ns - - 0.00
create+take_while(true)+subscribe 424.56 ns 0.37 ns 0.39 ns 0.96

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 1989.57 ns 19.34 ns 19.27 ns 1.00

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 2436.51 ns 115.82 ns 116.74 ns 0.99
create(1) + merge_with(create(2)) + subscribe 3864.59 ns 100.82 ns 102.04 ns 0.99

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 42.78 ns 30.92 ns 31.77 ns 0.97

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 1739.40 ns 110.67 ns 111.43 ns 0.99

ci-windows

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1726.24 ns 2.01 ns 2.34 ns 0.86
Subscribe empty callbacks to empty observable via pipe operator 1155.88 ns 2.00 ns 2.34 ns 0.86

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 3183.81 ns 7.23 ns 9.34 ns 0.77
from array of 1 - create + subscribe + current_thread 3865.38 ns 105.25 ns 113.50 ns 0.93
concat_as_source of just(1 immediate) create + subscribe 8628.79 ns 11.29 ns 15.25 ns 0.74

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 2345.33 ns 9.26 ns 9.39 ns 0.99
create+filter(true)+subscribe 1310.10 ns 6.24 ns 6.68 ns 0.93
create(1,2)+skip(1)+subscribe 1999.42 ns 9.22 ns 10.93 ns 0.84
create(1,1,2)+distinct_until_changed()+subscribe 1351.57 ns 12.72 ns 16.04 ns 0.79
create(1,2)+first()+subscribe 2873.99 ns 9.88 ns 10.69 ns 0.92
create(1,2)+last()+subscribe 1721.10 ns 12.82 ns 13.37 ns 0.96

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 1104.77 ns 4.03 ns 5.01 ns 0.80
current_thread scheduler create worker + schedule 1378.63 ns 9.85 ns 10.37 ns 0.95
current_thread scheduler create worker + schedule + recursive schedule 2384.35 ns 128.56 ns 135.29 ns 0.95

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 1306.59 ns 6.14 ns 6.68 ns 0.92
create+scan(10, std::plus)+subscribe 1553.34 ns 9.77 ns 9.77 ns 1.00
create+flat_map(just(v*2))+subscribe 4036.58 ns 254.82 ns 268.36 ns 0.95

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 1426.06 ns 5.66 ns 7.10 ns 0.80
create+take_while(true)+subscribe 1300.38 ns 5.96 ns 7.02 ns 0.85

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 4334.24 ns 85.23 ns 95.90 ns 0.89

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 5184.21 ns 307.14 ns 323.06 ns 0.95
create(1) + merge_with(create(2)) + subscribe 7982.95 ns 298.94 ns 318.30 ns 0.94

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 121.75 ns 98.06 ns 108.82 ns 0.90

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 5546.60 ns 276.54 ns 309.23 ns 0.89

Please sign in to comment.