[pre-commit.ci] pre-commit autoupdate

[pre-commit-ci]

updates:

• github.com/sirosen/check-jsonschema: 0.30.0 → 0.31.0

[coderabbitai]

Important

Review skipped

Bot user detected.

To trigger a single review, invoke the @coderabbitai review command.

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

---

Note

Free review on us!

CodeRabbit is offering free reviews until Wed Jan 15 2025 to showcase some of the refinements we've made.

🪧 Tips

Chat

There are 3 ways to chat with CodeRabbit:

• Review comments: Directly reply to a review comment made by CodeRabbit. Example:
  • I pushed a fix in commit <commit_id>, please review it.
  • Generate unit testing code for this file.
  • Open a follow-up GitHub issue for this discussion.
• Files and specific lines of code (under the "Files changed" tab): Tag @coderabbitai in a new review comment at the desired location with your query. Examples:
  • @coderabbitai generate unit testing code for this file.
  • @coderabbitai modularize this function.
• PR comments: Tag @coderabbitai in a new PR comment to ask questions about the PR branch. For the best results, please provide a very specific query, as very limited context is provided in this mode. Examples:
  • @coderabbitai gather interesting stats about this repository and render them as a table. Additionally, render a pie chart showing the language distribution in the codebase.
  • @coderabbitai read src/utils.ts and generate unit testing code.
  • @coderabbitai read the files in the src/scheduler package and generate a class diagram using mermaid and a README in the markdown format.
  • @coderabbitai help me debug CodeRabbit configuration file.

Note: Be mindful of the bot's finite context window. It's strongly recommended to break down tasks such as reading entire modules into smaller chunks. For a focused discussion, use review comments to chat about specific files and their changes, instead of using the PR comments.

CodeRabbit Commands (Invoked using PR comments)

• @coderabbitai pause to pause the reviews on a PR.
• @coderabbitai resume to resume the paused reviews.
• @coderabbitai review to trigger an incremental review. This is useful when automatic reviews are disabled for the repository.
• @coderabbitai full review to do a full review from scratch and review all the files again.
• @coderabbitai summary to regenerate the summary of the PR.
• @coderabbitai generate docstrings to generate docstrings for this PR. (Beta)
• @coderabbitai resolve resolve all the CodeRabbit review comments.
• @coderabbitai configuration to show the current CodeRabbit configuration for the repository.
• @coderabbitai help to get help.

Other keywords and placeholders

• Add @coderabbitai ignore anywhere in the PR description to prevent this PR from being reviewed.
• Add @coderabbitai summary to generate the high-level summary at a specific location in the PR description.
• Add @coderabbitai anywhere in the PR title to generate the title automatically.

CodeRabbit Configuration File (.coderabbit.yaml)

• You can programmatically configure CodeRabbit by adding a .coderabbit.yaml file to the root of your repository.
• Please see the configuration documentation for more information.
• If your editor has YAML language server enabled, you can add the path at the top of this file to enable auto-completion and validation: # yaml-language-server: $schema=https://coderabbit.ai/integrations/schema.v2.json

Documentation and Community

• Visit our Documentation for detailed information on how to use CodeRabbit.
• Join our Discord Community to get help, request features, and share feedback.
• Follow us on X/Twitter for updates and announcements.

[github-actions]

BENCHMARK RESULTS (AUTOGENERATED)

ci-ubuntu-gcc

General

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
Subscribe empty callbacks to empty observable	302.57 ns	1.54 ns	1.85 ns	0.83	1.85 ns
Subscribe empty callbacks to empty observable via pipe operator	302.81 ns	1.54 ns	1.85 ns	0.83	1.85 ns

Sources

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
from array of 1 - create + subscribe + immediate	697.90 ns	0.31 ns	0.31 ns	1.00	0.31 ns
from array of 1 - create + subscribe + current_thread	1048.71 ns	3.71 ns	3.71 ns	1.00	3.71 ns
concat_as_source of just(1 immediate) create + subscribe	2253.51 ns	112.26 ns	127.46 ns	0.88	114.01 ns
defer from array of 1 - defer + create + subscribe + immediate	782.67 ns	0.31 ns	0.31 ns	1.00	0.31 ns
interval - interval + take(3) + subscribe + immediate	2143.69 ns	59.23 ns	59.24 ns	1.00	59.23 ns
interval - interval + take(3) + subscribe + current_thread	2986.76 ns	32.46 ns	32.44 ns	1.00	33.97 ns
from array of 1 - create + as_blocking + subscribe + new_thread	29144.69 ns	27146.50 ns	27367.00 ns	0.99	27275.63 ns
from array of 1000 - create + as_blocking + subscribe + new_thread	39668.08 ns	51058.53 ns	51051.27 ns	1.00	50198.17 ns
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe	3551.74 ns	131.79 ns	134.47 ns	0.98	147.83 ns

Filtering Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take(1)+subscribe	1111.42 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+filter(true)+subscribe	839.42 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+skip(1)+subscribe	997.76 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,1,2)+distinct_until_changed()+subscribe	862.77 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+first()+subscribe	1403.72 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+last()+subscribe	910.57 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+take_last(1)+subscribe	1166.49 ns	17.90 ns	18.22 ns	0.98	19.15 ns
immediate_just(1,2,3)+element_at(1)+subscribe	825.57 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Schedulers

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate scheduler create worker + schedule	265.82 ns	0.46 ns	1.54 ns	0.30	1.54 ns
current_thread scheduler create worker + schedule	392.19 ns	4.63 ns	4.63 ns	1.00	4.63 ns
current_thread scheduler create worker + schedule + recursive schedule	813.24 ns	60.84 ns	60.48 ns	1.01	60.54 ns

Transforming Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+map(v*2)+subscribe	841.30 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+scan(10, std::plus)+subscribe	908.43 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+flat_map(immediate_just(v*2))+subscribe	2356.26 ns	150.83 ns	157.53 ns	0.96	188.94 ns
immediate_just+buffer(2)+subscribe	1554.35 ns	13.59 ns	13.59 ns	1.00	17.76 ns
immediate_just+window(2)+subscribe + subscsribe inner	2400.78 ns	1304.36 ns	1253.39 ns	1.04	1298.60 ns

Conditional Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take_while(false)+subscribe	825.54 ns	-	-	0.00	-
immediate_just+take_while(true)+subscribe	837.34 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Utility Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(1)+subscribe_on(immediate)+subscribe	2057.37 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Combining Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe	3458.03 ns	140.95 ns	142.34 ns	0.99	180.36 ns
immediate_just(1) + merge_with(immediate_just(2)) + subscribe	3747.52 ns	155.98 ns	168.15 ns	0.93	168.02 ns
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe	-	131.25 ns	143.02 ns	0.92	150.50 ns
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe	3623.12 ns	410.86 ns	380.11 ns	1.08	455.63 ns
immediate_just(1) + zip(immediate_just(2)) + subscribe	2199.39 ns	206.84 ns	216.26 ns	0.96	220.24 ns
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe	3233.52 ns	229.89 ns	228.85 ns	1.00	253.75 ns

Subjects

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
publish_subject with 1 observer - on_next	34.62 ns	14.72 ns	14.68 ns	1.00	14.87 ns
subscribe 100 observers to publish_subject	200600.80 ns	19615.12 ns	18642.48 ns	1.05	17764.74 ns
100 on_next to 100 observers to publish_subject	27117.25 ns	16663.59 ns	16700.15 ns	1.00	19844.81 ns

Scenarios

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
basic sample	1441.42 ns	13.90 ns	13.90 ns	1.00	22.27 ns
basic sample with immediate scheduler	1432.22 ns	5.55 ns	5.55 ns	1.00	16.37 ns
mix operators with disposables and without disposables	6418.93 ns	1398.02 ns	1428.64 ns	0.98	1870.14 ns
single disposable and looooooong indentity chain	25217.11 ns	932.40 ns	891.87 ns	1.05	5254.12 ns

Aggregating Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+reduce(10, std::plus)+subscribe	934.89 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Error Handling Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe	2090.47 ns	993.05 ns	993.76 ns	1.00	1014.96 ns
create(on_error())+retry(1)+subscribe	592.86 ns	107.89 ns	122.65 ns	0.88	120.15 ns

ci-macos

General

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
Subscribe empty callbacks to empty observable	369.54 ns	0.47 ns	0.47 ns	1.00	0.47 ns
Subscribe empty callbacks to empty observable via pipe operator	355.40 ns	0.47 ns	0.47 ns	1.00	0.47 ns

Sources

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
from array of 1 - create + subscribe + immediate	783.70 ns	0.34 ns	0.31 ns	1.09	0.31 ns
from array of 1 - create + subscribe + current_thread	962.50 ns	4.56 ns	4.06 ns	1.12	4.31 ns
concat_as_source of just(1 immediate) create + subscribe	2280.85 ns	177.35 ns	159.40 ns	1.11	177.07 ns
defer from array of 1 - defer + create + subscribe + immediate	731.29 ns	0.31 ns	0.31 ns	1.00	0.35 ns
interval - interval + take(3) + subscribe + immediate	2154.11 ns	55.99 ns	49.66 ns	1.13	55.45 ns
interval - interval + take(3) + subscribe + current_thread	2677.18 ns	32.62 ns	29.40 ns	1.11	32.67 ns
from array of 1 - create + as_blocking + subscribe + new_thread	20844.56 ns	19259.43 ns	21063.64 ns	0.91	17078.36 ns
from array of 1000 - create + as_blocking + subscribe + new_thread	26230.77 ns	23561.62 ns	24796.73 ns	0.95	23562.50 ns
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe	3044.01 ns	193.55 ns	177.06 ns	1.09	199.35 ns

Filtering Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take(1)+subscribe	1174.25 ns	0.34 ns	0.34 ns	1.00	0.34 ns
immediate_just+filter(true)+subscribe	825.91 ns	0.31 ns	0.34 ns	0.92	0.35 ns
immediate_just(1,2)+skip(1)+subscribe	1138.00 ns	0.34 ns	0.31 ns	1.09	0.34 ns
immediate_just(1,1,2)+distinct_until_changed()+subscribe	903.49 ns	0.34 ns	0.31 ns	1.09	0.34 ns
immediate_just(1,2)+first()+subscribe	1457.66 ns	0.31 ns	0.34 ns	0.94	0.34 ns
immediate_just(1,2)+last()+subscribe	1074.89 ns	0.76 ns	0.74 ns	1.02	1.00 ns
immediate_just+take_last(1)+subscribe	1120.45 ns	0.31 ns	0.34 ns	0.92	0.34 ns
immediate_just(1,2,3)+element_at(1)+subscribe	892.89 ns	0.36 ns	0.31 ns	1.16	0.32 ns

Schedulers

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate scheduler create worker + schedule	290.23 ns	0.51 ns	0.47 ns	1.09	0.50 ns
current_thread scheduler create worker + schedule	415.80 ns	4.54 ns	4.37 ns	1.04	4.37 ns
current_thread scheduler create worker + schedule + recursive schedule	743.90 ns	62.32 ns	61.63 ns	1.01	67.67 ns

Transforming Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+map(v*2)+subscribe	895.18 ns	2.79 ns	2.39 ns	1.17	2.82 ns
immediate_just+scan(10, std::plus)+subscribe	2125.67 ns	0.35 ns	0.34 ns	1.03	0.34 ns
immediate_just+flat_map(immediate_just(v*2))+subscribe	2239.70 ns	362.28 ns	198.62 ns	1.82	201.88 ns
immediate_just+buffer(2)+subscribe	1001.16 ns	15.84 ns	16.66 ns	0.95	18.08 ns
immediate_just+window(2)+subscribe + subscsribe inner	2940.02 ns	1156.18 ns	1054.63 ns	1.10	1089.29 ns

Conditional Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take_while(false)+subscribe	864.27 ns	-	-	0.00	-
immediate_just+take_while(true)+subscribe	891.95 ns	0.34 ns	0.31 ns	1.09	0.34 ns

Utility Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(1)+subscribe_on(immediate)+subscribe	2031.48 ns	1.99 ns	1.78 ns	1.11	1.94 ns

Combining Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe	3092.64 ns	224.47 ns	202.57 ns	1.11	226.88 ns
immediate_just(1) + merge_with(immediate_just(2)) + subscribe	3310.51 ns	221.54 ns	199.04 ns	1.11	225.34 ns
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe	-	223.64 ns	211.28 ns	1.06	225.88 ns
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe	3488.97 ns	619.48 ns	500.00 ns	1.24	553.00 ns
immediate_just(1) + zip(immediate_just(2)) + subscribe	2178.98 ns	369.45 ns	325.38 ns	1.14	363.93 ns
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe	3055.93 ns	353.74 ns	322.43 ns	1.10	352.40 ns

Subjects

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
publish_subject with 1 observer - on_next	45.96 ns	24.46 ns	21.49 ns	1.14	24.10 ns
subscribe 100 observers to publish_subject	127744.75 ns	17505.12 ns	16446.23 ns	1.06	18532.18 ns
100 on_next to 100 observers to publish_subject	31889.31 ns	14071.36 ns	14021.38 ns	1.00	14373.85 ns

Scenarios

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
basic sample	1174.35 ns	11.53 ns	11.24 ns	1.03	25.84 ns
basic sample with immediate scheduler	1166.18 ns	5.03 ns	5.00 ns	1.00	11.88 ns
mix operators with disposables and without disposables	7197.41 ns	1322.65 ns	1335.78 ns	0.99	1576.92 ns
single disposable and looooooong indentity chain	17204.37 ns	1721.78 ns	1542.23 ns	1.12	3812.64 ns

Aggregating Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+reduce(10, std::plus)+subscribe	972.33 ns	0.34 ns	0.31 ns	1.08	0.31 ns

Error Handling Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe	3405.98 ns	2641.79 ns	2554.51 ns	1.03	2725.88 ns
create(on_error())+retry(1)+subscribe	756.22 ns	168.63 ns	168.44 ns	1.00	187.34 ns

ci-ubuntu-clang

General

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
Subscribe empty callbacks to empty observable	268.26 ns	0.64 ns	1.54 ns	0.42	1.55 ns
Subscribe empty callbacks to empty observable via pipe operator	272.00 ns	0.63 ns	1.54 ns	0.41	1.54 ns

Sources

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
from array of 1 - create + subscribe + immediate	575.67 ns	0.31 ns	0.31 ns	1.00	0.31 ns
from array of 1 - create + subscribe + current_thread	791.68 ns	4.01 ns	4.01 ns	1.00	4.01 ns
concat_as_source of just(1 immediate) create + subscribe	2355.27 ns	129.05 ns	129.58 ns	1.00	130.26 ns
defer from array of 1 - defer + create + subscribe + immediate	780.22 ns	0.31 ns	0.31 ns	1.00	0.31 ns
interval - interval + take(3) + subscribe + immediate	2207.59 ns	58.31 ns	58.26 ns	1.00	58.35 ns
interval - interval + take(3) + subscribe + current_thread	3161.79 ns	31.02 ns	30.86 ns	1.01	31.50 ns
from array of 1 - create + as_blocking + subscribe + new_thread	30650.39 ns	27830.35 ns	28883.91 ns	0.96	28186.56 ns
from array of 1000 - create + as_blocking + subscribe + new_thread	40265.17 ns	33713.30 ns	33175.50 ns	1.02	38067.21 ns
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe	3664.07 ns	146.67 ns	148.40 ns	0.99	148.78 ns

Filtering Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take(1)+subscribe	1165.22 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+filter(true)+subscribe	840.78 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+skip(1)+subscribe	1083.33 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,1,2)+distinct_until_changed()+subscribe	880.16 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+first()+subscribe	1366.63 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2)+last()+subscribe	1008.53 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+take_last(1)+subscribe	1192.81 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just(1,2,3)+element_at(1)+subscribe	858.41 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Schedulers

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate scheduler create worker + schedule	279.20 ns	1.54 ns	0.63 ns	2.43	0.63 ns
current_thread scheduler create worker + schedule	405.87 ns	4.01 ns	4.32 ns	0.93	4.01 ns
current_thread scheduler create worker + schedule + recursive schedule	850.18 ns	54.99 ns	54.93 ns	1.00	56.31 ns

Transforming Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+map(v*2)+subscribe	843.33 ns	0.31 ns	0.31 ns	1.00	0.31 ns
immediate_just+scan(10, std::plus)+subscribe	967.96 ns	0.62 ns	0.62 ns	1.00	0.32 ns
immediate_just+flat_map(immediate_just(v*2))+subscribe	2241.79 ns	138.88 ns	135.62 ns	1.02	134.28 ns
immediate_just+buffer(2)+subscribe	1547.10 ns	14.19 ns	13.89 ns	1.02	14.52 ns
immediate_just+window(2)+subscribe + subscsribe inner	2455.90 ns	896.08 ns	898.41 ns	1.00	902.55 ns

Conditional Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take_while(false)+subscribe	848.94 ns	-	-	0.00	-
immediate_just+take_while(true)+subscribe	848.90 ns	0.31 ns	0.31 ns	0.99	0.31 ns

Utility Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(1)+subscribe_on(immediate)+subscribe	2038.93 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Combining Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe	3292.48 ns	160.28 ns	158.68 ns	1.01	156.54 ns
immediate_just(1) + merge_with(immediate_just(2)) + subscribe	3756.17 ns	142.40 ns	137.34 ns	1.04	140.34 ns
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe	-	142.70 ns	142.68 ns	1.00	138.14 ns
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe	3423.19 ns	378.26 ns	377.78 ns	1.00	379.51 ns
immediate_just(1) + zip(immediate_just(2)) + subscribe	2247.75 ns	202.04 ns	203.60 ns	0.99	202.59 ns
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe	3260.10 ns	223.89 ns	221.76 ns	1.01	223.18 ns

Subjects

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
publish_subject with 1 observer - on_next	52.19 ns	19.54 ns	19.63 ns	1.00	23.09 ns
subscribe 100 observers to publish_subject	206418.83 ns	17398.01 ns	17329.51 ns	1.00	17306.76 ns
100 on_next to 100 observers to publish_subject	46046.40 ns	20116.33 ns	20087.89 ns	1.00	20129.81 ns

Scenarios

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
basic sample	1310.20 ns	11.42 ns	11.42 ns	1.00	20.68 ns
basic sample with immediate scheduler	1312.97 ns	5.86 ns	5.86 ns	1.00	6.48 ns
mix operators with disposables and without disposables	6502.02 ns	1181.31 ns	1168.97 ns	1.01	1463.04 ns
single disposable and looooooong indentity chain	27354.60 ns	1244.98 ns	1233.92 ns	1.01	4600.49 ns

Aggregating Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+reduce(10, std::plus)+subscribe	991.12 ns	0.31 ns	0.31 ns	1.00	0.31 ns

Error Handling Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe	2172.51 ns	1190.51 ns	1159.09 ns	1.03	1171.93 ns
create(on_error())+retry(1)+subscribe	657.44 ns	138.27 ns	137.68 ns	1.00	138.65 ns

ci-windows

General

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
Subscribe empty callbacks to empty observable	584.52 ns	2.16 ns	2.16 ns	1.00	2.16 ns
Subscribe empty callbacks to empty observable via pipe operator	592.96 ns	2.16 ns	2.16 ns	1.00	2.16 ns

Sources

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
from array of 1 - create + subscribe + immediate	1161.36 ns	5.24 ns	5.24 ns	1.00	5.86 ns
from array of 1 - create + subscribe + current_thread	1438.45 ns	15.44 ns	15.45 ns	1.00	15.75 ns
concat_as_source of just(1 immediate) create + subscribe	3698.56 ns	167.91 ns	166.28 ns	1.01	176.93 ns
defer from array of 1 - defer + create + subscribe + immediate	1214.64 ns	5.24 ns	5.24 ns	1.00	5.86 ns
interval - interval + take(3) + subscribe + immediate	3324.75 ns	139.58 ns	139.40 ns	1.00	141.48 ns
interval - interval + take(3) + subscribe + current_thread	3415.20 ns	59.96 ns	60.69 ns	0.99	61.10 ns
from array of 1 - create + as_blocking + subscribe + new_thread	128466.67 ns	121790.00 ns	113810.00 ns	1.07	122812.50 ns
from array of 1000 - create + as_blocking + subscribe + new_thread	138750.00 ns	138600.00 ns	131777.78 ns	1.05	140333.33 ns
concat_as_source of just(1 immediate) and just(1,2 immediate)create + subscribe	5356.81 ns	198.74 ns	205.11 ns	0.97	206.82 ns

Filtering Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take(1)+subscribe	1843.68 ns	19.42 ns	19.42 ns	1.00	20.36 ns
immediate_just+filter(true)+subscribe	1626.06 ns	18.50 ns	18.51 ns	1.00	20.98 ns
immediate_just(1,2)+skip(1)+subscribe	1745.66 ns	17.88 ns	17.89 ns	1.00	20.38 ns
immediate_just(1,1,2)+distinct_until_changed()+subscribe	1360.56 ns	20.71 ns	20.67 ns	1.00	25.58 ns
immediate_just(1,2)+first()+subscribe	2373.33 ns	18.19 ns	18.21 ns	1.00	18.52 ns
immediate_just(1,2)+last()+subscribe	1473.01 ns	19.12 ns	19.13 ns	1.00	22.22 ns
immediate_just+take_last(1)+subscribe	2016.85 ns	64.28 ns	64.33 ns	1.00	70.52 ns
immediate_just(1,2,3)+element_at(1)+subscribe	1648.67 ns	20.96 ns	21.00 ns	1.00	22.84 ns

Schedulers

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate scheduler create worker + schedule	529.88 ns	5.15 ns	4.63 ns	1.11	4.01 ns
current_thread scheduler create worker + schedule	661.94 ns	11.72 ns	12.04 ns	0.97	11.87 ns
current_thread scheduler create worker + schedule + recursive schedule	1353.99 ns	98.36 ns	97.87 ns	1.00	97.10 ns

Transforming Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+map(v*2)+subscribe	1328.31 ns	18.80 ns	18.81 ns	1.00	21.27 ns
immediate_just+scan(10, std::plus)+subscribe	1436.76 ns	20.96 ns	20.96 ns	1.00	22.83 ns
immediate_just+flat_map(immediate_just(v*2))+subscribe	3789.20 ns	184.61 ns	192.73 ns	0.96	203.78 ns
immediate_just+buffer(2)+subscribe	2348.27 ns	65.17 ns	65.44 ns	1.00	67.59 ns
immediate_just+window(2)+subscribe + subscsribe inner	4010.74 ns	1213.33 ns	1287.75 ns	0.94	1211.26 ns

Conditional Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+take_while(false)+subscribe	1312.41 ns	17.57 ns	17.57 ns	1.00	19.11 ns
immediate_just+take_while(true)+subscribe	1320.13 ns	18.50 ns	18.51 ns	1.00	20.98 ns

Utility Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(1)+subscribe_on(immediate)+subscribe	3620.06 ns	11.10 ns	11.11 ns	1.00	11.11 ns

Combining Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just(immediate_just(1), immediate_just(1)) + merge() + subscribe	5120.38 ns	197.63 ns	215.58 ns	0.92	214.86 ns
immediate_just(1) + merge_with(immediate_just(2)) + subscribe	5750.00 ns	190.24 ns	188.63 ns	1.01	204.45 ns
immediate_just(1) + with_latest_from(immediate_just(2)) + subscribe	-	195.15 ns	190.29 ns	1.03	199.88 ns
immediate_just(immediate_just(1),immediate_just(1)) + switch_on_next() + subscribe	6054.71 ns	450.83 ns	438.18 ns	1.03	454.27 ns
immediate_just(1) + zip(immediate_just(2)) + subscribe	3553.44 ns	511.98 ns	529.11 ns	0.97	515.23 ns
immediate_just(immediate_just(1), immediate_just(1)) + concat() + subscribe	4875.91 ns	323.91 ns	326.94 ns	0.99	339.29 ns

Subjects

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
publish_subject with 1 observer - on_next	36.09 ns	29.03 ns	48.27 ns	0.60	30.20 ns
subscribe 100 observers to publish_subject	265750.00 ns	25790.00 ns	26105.26 ns	0.99	25987.18 ns
100 on_next to 100 observers to publish_subject	55000.00 ns	33209.38 ns	32794.29 ns	1.01	35989.29 ns

Scenarios

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
basic sample	1880.70 ns	96.26 ns	97.15 ns	0.99	112.90 ns
basic sample with immediate scheduler	1894.99 ns	68.18 ns	66.49 ns	1.03	82.88 ns
mix operators with disposables and without disposables	10223.47 ns	1855.89 ns	1851.14 ns	1.00	2515.49 ns
single disposable and looooooong indentity chain	26853.33 ns	1742.76 ns	1597.48 ns	1.09	6422.35 ns

Aggregating Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
immediate_just+reduce(10, std::plus)+subscribe	1471.29 ns	19.11 ns	19.13 ns	1.00	21.90 ns

Error Handling Operators

name	rxcpp	rpp	prev rpp	ratio	rpp no optimization
create(on_next(1), on_error())+on_error_resume_next(immediate_just(2)))+subscribe	2314.51 ns	355.48 ns	354.12 ns	1.00	368.15 ns
create(on_error())+retry(1)+subscribe	1517.79 ns	139.37 ns	137.85 ns	1.01	139.13 ns

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 98.62%. Comparing base (9ab9e07) to head (59c9a47).
Report is 1 commits behind head on v2.

Additional details and impacted files

@@           Coverage Diff           @@
##               v2     #699   +/-   ##
=======================================
  Coverage   98.62%   98.62%           
=======================================
  Files         156      156           
  Lines        9800     9800           
=======================================
  Hits         9665     9665           
  Misses        135      135           

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud