Skip to content

Commit

Permalink
minor docs fix
Browse files Browse the repository at this point in the history
  • Loading branch information
@victimsnino
victimsnino committed Aug 1, 2023
1 parent b0afc94 commit bcd1639
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/rpp/rpp/schedulers/current_thread.hpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ namespace rpp::schedulers
* - "Task 4"
*
* @par How to use it properly?
* To have any visible impact you need to use it at least **twice** during same observable. For example, `rpp::source::just` source uses it as default scheduler as well as `rpp::operators::subscribe_on` operator.
* To have any visible impact you need to use it at least **twice** during same observable. For example, `rpp::source::just` source uses it as default scheduler as well as `rpp::operators::merge` operator (which just "owns" it during subscription).
*
* For example, this one
* ```cpp
Expand Down

1 comment on commit bcd1639

@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 719.13 ns 1.45 ns 1.49 ns 0.97
Subscribe empty callbacks to empty observable via pipe operator 645.33 ns 1.59 ns 1.52 ns 1.05

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 1880.43 ns 0.68 ns 0.37 ns 1.83
from array of 1 - create + subscribe + current_thread 2371.40 ns 47.17 ns 45.32 ns 1.04
concat_as_source of just(1 immediate) create + subscribe 5634.98 ns 0.33 ns 0.38 ns 0.86

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 1460.75 ns 0.37 ns 0.40 ns 0.93
create+filter(true)+subscribe 906.79 ns 0.33 ns 0.42 ns 0.79
create(1,2)+skip(1)+subscribe 1159.22 ns 0.37 ns 0.40 ns 0.93
create(1,1,2)+distinct_until_changed()+subscribe 924.93 ns 0.40 ns 0.40 ns 1.01
create(1,2)+first()+subscribe 1868.65 ns 0.32 ns 0.41 ns 0.79
create(1,2)+last()+subscribe 1211.26 ns 0.29 ns 0.39 ns 0.76

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 840.12 ns 0.94 ns 1.16 ns 0.81
current_thread scheduler create worker + schedule 825.14 ns 8.80 ns 8.50 ns 1.04
current_thread scheduler create worker + schedule + recursive schedule 1753.93 ns 80.67 ns 96.51 ns 0.84

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 857.76 ns 0.35 ns 0.37 ns 0.94
create+scan(10, std::plus)+subscribe 1020.99 ns 0.33 ns 0.37 ns 0.88
create+flat_map(just(v*2))+subscribe 3388.66 ns 138.58 ns 172.32 ns 0.80

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 769.94 ns - - 0.00
create+take_while(true)+subscribe 954.46 ns 0.34 ns 0.37 ns 0.91

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 3349.25 ns 35.04 ns 38.06 ns 0.92

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 4739.71 ns 201.67 ns 201.28 ns 1.00
create(1) + merge_with(create(2)) + subscribe 7433.27 ns 163.03 ns 197.85 ns 0.82

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 123.82 ns 93.97 ns 91.78 ns 1.02

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 4477.41 ns 107.47 ns 130.89 ns 0.82

ci-macos

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1103.64 ns 0.56 ns 0.56 ns 1.00
Subscribe empty callbacks to empty observable via pipe operator 1102.24 ns 0.56 ns 0.56 ns 1.00

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 2438.35 ns 0.44 ns 0.44 ns 1.00
from array of 1 - create + subscribe + current_thread 2942.08 ns 94.57 ns 101.24 ns 0.93
concat_as_source of just(1 immediate) create + subscribe 7078.09 ns 0.28 ns 0.28 ns 1.00

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 2005.03 ns 3.68 ns 3.57 ns 1.03
create+filter(true)+subscribe 1163.68 ns 2.81 ns 2.78 ns 1.01
create(1,2)+skip(1)+subscribe 1832.41 ns 5.28 ns 5.28 ns 1.00
create(1,1,2)+distinct_until_changed()+subscribe 1193.30 ns 8.01 ns 7.82 ns 1.02
create(1,2)+first()+subscribe 2315.65 ns 5.56 ns 5.55 ns 1.00
create(1,2)+last()+subscribe 1462.27 ns 7.78 ns 7.78 ns 1.00

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 1036.37 ns 0.56 ns 0.54 ns 1.03
current_thread scheduler create worker + schedule 1344.00 ns 9.50 ns 9.47 ns 1.00
current_thread scheduler create worker + schedule + recursive schedule 2347.37 ns 160.83 ns 154.10 ns 1.04

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 1153.21 ns 2.78 ns 2.71 ns 1.03
create+scan(10, std::plus)+subscribe 1738.65 ns 4.72 ns 4.33 ns 1.09
create+flat_map(just(v*2))+subscribe 3314.16 ns 290.18 ns 289.46 ns 1.00

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 1216.32 ns 3.35 ns 3.26 ns 1.03
create+take_while(true)+subscribe 1148.71 ns 2.51 ns 2.43 ns 1.03

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 3642.60 ns 86.11 ns 84.53 ns 1.02

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 3991.10 ns 334.70 ns 322.56 ns 1.04
create(1) + merge_with(create(2)) + subscribe 6774.18 ns 344.27 ns 331.44 ns 1.04

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 102.32 ns 97.34 ns 93.15 ns 1.04

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 4367.71 ns 232.28 ns 240.72 ns 0.96

ci-ubuntu-clang

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 417.26 ns 2.33 ns 1.56 ns 1.49
Subscribe empty callbacks to empty observable via pipe operator 412.84 ns 1.22 ns 1.54 ns 0.80

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 888.36 ns 0.43 ns 0.38 ns 1.14
from array of 1 - create + subscribe + current_thread 1209.55 ns 33.81 ns 30.56 ns 1.11
concat_as_source of just(1 immediate) create + subscribe 2734.92 ns 0.40 ns 0.38 ns 1.05

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 773.71 ns 0.40 ns 0.39 ns 1.04
create+filter(true)+subscribe 444.96 ns 0.40 ns 0.38 ns 1.04
create(1,2)+skip(1)+subscribe 687.31 ns 0.40 ns 0.39 ns 1.03
create(1,1,2)+distinct_until_changed()+subscribe 465.21 ns 0.84 ns 0.78 ns 1.08
create(1,2)+first()+subscribe 905.68 ns 0.40 ns 0.38 ns 1.05
create(1,2)+last()+subscribe 580.13 ns 0.41 ns 0.37 ns 1.08

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 330.90 ns 1.20 ns 1.14 ns 1.05
current_thread scheduler create worker + schedule 607.05 ns 9.63 ns 8.29 ns 1.16
current_thread scheduler create worker + schedule + recursive schedule 996.23 ns 85.04 ns 77.18 ns 1.10

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 443.06 ns 0.41 ns 0.38 ns 1.06
create+scan(10, std::plus)+subscribe 530.66 ns 0.81 ns 0.77 ns 1.05
create+flat_map(just(v*2))+subscribe 1948.46 ns 98.42 ns 90.82 ns 1.08

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 476.18 ns - - 0.00
create+take_while(true)+subscribe 448.29 ns 0.40 ns 0.37 ns 1.09

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 2107.38 ns 23.45 ns 19.34 ns 1.21

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 2563.05 ns 122.83 ns 115.82 ns 1.06
create(1) + merge_with(create(2)) + subscribe 3983.11 ns 111.88 ns 100.82 ns 1.11

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 46.19 ns 31.81 ns 30.92 ns 1.03

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 1812.29 ns 119.81 ns 110.67 ns 1.08

ci-windows

General
name rxcpp rpp prev rpp ratio
Subscribe empty callbacks to empty observable 1499.58 ns 2.09 ns 2.01 ns 1.04
Subscribe empty callbacks to empty observable via pipe operator 2049.82 ns 2.42 ns 2.00 ns 1.21

Sources
name rxcpp rpp prev rpp ratio
from array of 1 - create + subscribe + immediate 3906.00 ns 11.68 ns 7.23 ns 1.61
from array of 1 - create + subscribe + current_thread 4464.29 ns 150.13 ns 105.25 ns 1.43
concat_as_source of just(1 immediate) create + subscribe 10667.31 ns 16.71 ns 11.29 ns 1.48

Filtering Operators
name rxcpp rpp prev rpp ratio
create+take(1)+subscribe 2986.39 ns 11.13 ns 9.26 ns 1.20
create+filter(true)+subscribe 1673.60 ns 9.11 ns 6.24 ns 1.46
create(1,2)+skip(1)+subscribe 2550.76 ns 12.95 ns 9.22 ns 1.40
create(1,1,2)+distinct_until_changed()+subscribe 2342.58 ns 18.70 ns 12.72 ns 1.47
create(1,2)+first()+subscribe 3296.13 ns 14.05 ns 9.88 ns 1.42
create(1,2)+last()+subscribe 2257.58 ns 17.88 ns 12.82 ns 1.39

Schedulers
name rxcpp rpp prev rpp ratio
immediate scheduler create worker + schedule 1373.95 ns 6.36 ns 4.03 ns 1.58
current_thread scheduler create worker + schedule 2375.12 ns 15.46 ns 9.85 ns 1.57
current_thread scheduler create worker + schedule + recursive schedule 2726.14 ns 161.21 ns 128.56 ns 1.25

Transforming Operators
name rxcpp rpp prev rpp ratio
create+map(v*2)+subscribe 1611.61 ns 8.80 ns 6.14 ns 1.43
create+scan(10, std::plus)+subscribe 1870.76 ns 12.43 ns 9.77 ns 1.27
create+flat_map(just(v*2))+subscribe 4829.52 ns 310.12 ns 254.82 ns 1.22

Conditional Operators
name rxcpp rpp prev rpp ratio
create+take_while(false)+subscribe 1733.75 ns 8.03 ns 5.66 ns 1.42
create+take_while(true)+subscribe 1688.93 ns 8.93 ns 5.96 ns 1.50

Utility Operators
name rxcpp rpp prev rpp ratio
create(1)+subscribe_on(immediate)+subscribe 5631.82 ns 131.88 ns 85.23 ns 1.55

Combining Operators
name rxcpp rpp prev rpp ratio
create(create(1), create(1)) + merge() + subscribe 6344.96 ns 401.77 ns 307.14 ns 1.31
create(1) + merge_with(create(2)) + subscribe 10816.35 ns 348.06 ns 298.94 ns 1.16

Subjects
name rxcpp rpp prev rpp ratio
publish_subject with 1 observer - on_next 135.24 ns 104.68 ns 98.06 ns 1.07

Scenarios
name rxcpp rpp prev rpp ratio
basic sample 12249.40 ns 376.52 ns 276.54 ns 1.36

Please sign in to comment.