Add test for "flat_map" about error or error in the middle

[tcw165]

No description provided.

[codecov]

Codecov Report

Merging #191 (9efa721) into main (45f7fe9) will not change coverage.
The diff coverage is n/a.

@@           Coverage Diff           @@
##             main     #191   +/-   ##
=======================================
  Coverage   99.70%   99.70%           
=======================================
  Files          79       79           
  Lines        1017     1017           
=======================================
  Hits         1014     1014           
  Misses          3        3           

Help us with your feedback. Take ten seconds to tell us how you rate us.

[github-actions]

Linux CLANG

Observable construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable construction	0.34ns	0.401211	0.84	0.34ns
Dynamic observable construction	29.21ns	31.406	0.93	24.48ns
Specific observable construction + as_dynamic	29.19ns	31.6899	0.92	24.44ns

Observable lift

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable lift specific observer	71.00ns	78.0714	0.91	289.82ns
Specific observable lift dynamic observer	94.47ns	105.344	0.90	306.04ns
Dynamic observable lift specific observer	157.62ns	159.642	0.99	335.98ns
Dynamic observable lift dynamic observer	163.78ns	178.354	0.92	323.99ns

Observable subscribe

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe specific observer	45.25ns	48.6518	0.93	288.10ns
Specific observable subscribe dynamic observer	58.29ns	62.3166	0.94	296.17ns
Dynamic observable subscribe specific observer	112.21ns	111.482	1.01	329.81ns
Dynamic observable subscribe dynamic observer	109.25ns	115.011	0.95	313.92ns

Observable subscribe #2

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe lambda	45.20ns	48.6262	0.93	292.60ns
Dynamic observable subscribe lambda	109.97ns	111.332	0.99	331.20ns
Specific observable subscribe lambda without subscription	45.47ns	48.6678	0.93	286.63ns
Dynamic observable subscribe lambda without subscription	110.58ns	111.416	0.99	328.68ns
Specific observable subscribe specific subscriber	16.78ns	16.0941	1.04	225.18ns
Dynamic observable subscribe specific subscriber	78.61ns	78.5089	1.00	266.21ns
Specific observable subscribe dynamic observer	16.75ns	16.0529	1.04	239.52ns
Dynamic observable subscribe dynamic observer	63.18ns	68.3207	0.92	256.75ns

Observer construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer construction	0.67ns	0.401732	1.67	0.33ns
Dynamic observer construction	29.15ns	31.3966	0.93	21.56ns
Specific observer construction + as_dynamic	29.99ns	31.6266	0.95	21.64ns

OnNext

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer OnNext	0.67ns	0.802897	0.83	0.67ns
Dynamic observer OnNext	1.68ns	1.6076	1.04	2.34ns

Operators

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
map construction from observable via dot + subscribe	71.31ns	75.9552	0.94	241.10ns

Subscriber construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Make subsriber	32.49ns	32.75	0.99	64.20ns
Make copy of subscriber	16.72ns	18.8456	0.89	4.70ns
Transform subsriber to dynamic	46.57ns	47.0575	0.99	26.71ns

Subscription

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
composite_subscription create	31.53ns	33.4229	0.94	52.32ns
composite_subscription add	45.60ns	48.4643	0.94	20.58ns
composite_subscription unsubscribe	6.03ns	8.02493	0.75	10.70ns

foundamental sources

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
empty	16.74ns	16.0926	1.04	35.40ns
error	49.23ns	48.3334	1.02	77.10ns
never	16.75ns	16.0553	1.04	235.03ns

from

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
from vector with int	27.79ns	25.4266	1.09	58.93ns

just

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
just send int	16.78ns	16.1086	1.04	36.43ns
just send variadic	16.78ns	18.9197	0.89	42.23ns

merge

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
merge	17.39ns	16.7405	1.04	125.82ns
merge_with	79.28ns	77.0388	1.03	296.65ns

publish_subject callbacks

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
on_next	24.39ns	29.5349	0.83	10.27ns
on_error	2.02ns	2.02182	1.00	19.18ns
on_completed	2.02ns	1.6732	1.21	0.67ns

publish_subject routines

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
construct	167.68ns	163.955	1.02	181.10ns
get_observable	29.13ns	33.7818	0.86	50.67ns
get_subscriber	62.25ns	67.6188	0.92	14.18ns

Linux GCC

Observable construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable construction	0.34ns	0.402115	0.83	0.34ns
Dynamic observable construction	19.30ns	17.3313	1.11	23.24ns
Specific observable construction + as_dynamic	18.78ns	17.2935	1.09	22.81ns

Observable lift

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable lift specific observer	27.33ns	24.8898	1.10	343.92ns
Specific observable lift dynamic observer	31.95ns	27.6024	1.16	359.04ns
Dynamic observable lift specific observer	75.30ns	75.406	1.00	400.82ns
Dynamic observable lift dynamic observer	68.31ns	72.8159	0.94	381.20ns

Observable subscribe

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe specific observer	23.05ns	20.3498	1.13	333.51ns
Specific observable subscribe dynamic observer	58.92ns	20.6469	2.85	339.21ns
Dynamic observable subscribe specific observer	51.44ns	49.2964	1.04	386.81ns
Dynamic observable subscribe dynamic observer	39.92ns	35.6147	1.12	369.17ns

Observable subscribe #2

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe lambda	23.18ns	20.3576	1.14	333.24ns
Dynamic observable subscribe lambda	52.75ns	49.7887	1.06	399.56ns
Specific observable subscribe lambda without subscription	23.41ns	20.9768	1.12	333.59ns
Dynamic observable subscribe lambda without subscription	58.67ns	58.8773	1.00	409.68ns
Specific observable subscribe specific subscriber	3.68ns	6.02573	0.61	279.38ns
Dynamic observable subscribe specific subscriber	30.90ns	28.8906	1.07	326.38ns
Specific observable subscribe dynamic observer	3.67ns	6.01412	0.61	284.56ns
Dynamic observable subscribe dynamic observer	15.29ns	17.2259	0.89	312.19ns

Observer construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer construction	0.34ns	0.426316	0.79	0.33ns
Dynamic observer construction	19.16ns	17.302	1.11	20.50ns
Specific observer construction + as_dynamic	19.38ns	18.1247	1.07	20.41ns

OnNext

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer OnNext	0.34ns	0.428938	0.78	0.33ns
Dynamic observer OnNext	2.01ns	2.00927	1.00	1.74ns

Operators

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
map construction from observable via dot + subscribe	14.91ns	24.4478	0.61	348.45ns

Subscriber construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Make subsriber	21.36ns	21.1291	1.01	57.99ns
Make copy of subscriber	3.72ns	6.024	0.62	4.49ns
Transform subsriber to dynamic	21.80ns	20.1478	1.08	29.09ns

Subscription

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
composite_subscription create	21.57ns	19.6334	1.10	55.32ns
composite_subscription add	21.90ns	26.9281	0.81	17.34ns
composite_subscription unsubscribe	8.38ns	8.03432	1.04	10.04ns

foundamental sources

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
empty	3.46ns	5.95029	0.58	48.78ns
error	35.78ns	37.7911	0.95	82.49ns
never	3.57ns	5.84656	0.61	282.69ns

from

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
from vector with int	22.51ns	19.607	1.15	70.09ns

just

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
just send int	3.65ns	5.64254	0.65	52.65ns
just send variadic	4.08ns	5.87399	0.69	48.07ns

merge

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
merge	3.95ns	5.97772	0.66	147.57ns
merge_with	43.04ns	41.5551	1.04	358.25ns

publish_subject callbacks

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
on_next	17.07ns	19.832	0.86	11.71ns
on_error	1.01ns	1.21005	0.83	16.82ns
on_completed	1.34ns	1.20773	1.11	1.35ns

publish_subject routines

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
construct	120.55ns	120.465	1.00	171.64ns
get_observable	5.22ns	5.79179	0.90	46.25ns
get_subscriber	12.26ns	16.0881	0.76	22.39ns

Windows MSVC

Observable construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable construction	2.02ns	2.01257	1.00	0.81ns
Dynamic observable construction	69.16ns	70.2194	0.98	126.52ns
Specific observable construction + as_dynamic	69.37ns	69.8867	0.99	126.78ns

Observable lift

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable lift specific observer	140.37ns	135.72	1.03	1218.81ns
Specific observable lift dynamic observer	172.66ns	167.757	1.03	1262.15ns
Dynamic observable lift specific observer	251.06ns	247.49	1.01	1393.06ns
Dynamic observable lift dynamic observer	228.10ns	227.954	1.00	1290.00ns

Observable subscribe

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe specific observer	94.80ns	92.7621	1.02	1167.00ns
Specific observable subscribe dynamic observer	114.14ns	109.507	1.04	1190.05ns
Dynamic observable subscribe specific observer	200.61ns	196.643	1.02	1342.58ns
Dynamic observable subscribe dynamic observer	164.08ns	161.83	1.01	1231.10ns

Observable subscribe #2

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observable subscribe lambda	92.00ns	92.4461	1.00	1170.27ns
Dynamic observable subscribe lambda	197.62ns	194.906	1.01	1347.63ns
Specific observable subscribe lambda without subscription	92.50ns	91.8507	1.01	1172.77ns
Dynamic observable subscribe lambda without subscription	196.88ns	197.484	1.00	1342.89ns
Specific observable subscribe specific subscriber	16.12ns	16.0609	1.00	860.69ns
Dynamic observable subscribe specific subscriber	121.47ns	122.543	0.99	1059.63ns
Specific observable subscribe dynamic observer	16.13ns	18.8784	0.85	886.75ns
Dynamic observable subscribe dynamic observer	70.30ns	70.6967	0.99	919.22ns

Observer construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer construction	0.42ns	0.419082	1.00	2.03ns
Dynamic observer construction	71.91ns	70.7703	1.02	111.85ns
Specific observer construction + as_dynamic	70.60ns	69.5359	1.02	111.39ns

OnNext

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Specific observer OnNext	0.44ns	0.446831	0.98	0.45ns
Dynamic observer OnNext	1.63ns	1.63179	1.00	2.01ns

Operators

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
map construction from observable via dot + subscribe	88.66ns	89.1805	0.99	1007.12ns

Subscriber construction

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
Make subsriber	74.01ns	74.3114	1.00	322.61ns
Make copy of subscriber	16.07ns	16.0784	1.00	34.17ns
Transform subsriber to dynamic	87.25ns	88.5664	0.99	150.41ns

Subscription

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
composite_subscription create	73.83ns	73.7403	1.00	316.01ns
composite_subscription add	65.30ns	64.55	1.01	62.90ns
composite_subscription unsubscribe	8.04ns	8.03208	1.00	26.27ns

foundamental sources

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
empty	16.13ns	16.1301	1.00	186.55ns
error	55.31ns	52.4884	1.05	233.95ns
never	16.05ns	16.099	1.00	859.35ns

from

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
from vector with int	73.97ns	76.724	0.96	241.10ns

just

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
just send int	23.46ns	23.3789	1.00	184.63ns
just send variadic	24.25ns	24.5222	0.99	187.17ns

merge

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
merge	41.09ns	41.0708	1.00	661.07ns
merge_with	289.22ns	288.821	1.00	1457.76ns

publish_subject callbacks

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
on_next	22.68ns	22.5661	1.00	29.33ns
on_error	2.28ns	2.39006	0.95	22.09ns
on_completed	1.96ns	1.9556	1.00	0.82ns

publish_subject routines

Table

Test Name	Current, ns	Prev, ns	Ratio	RxCpp current, ns
construct	281.02ns	271.524	1.03	605.16ns
get_observable	31.14ns	30.9357	1.01	155.07ns
get_subscriber	61.88ns	61.6165	1.00	99.98ns