| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/ |
| H A D | ObservableBindingTest.cs | 45 OnNext(40, 0), in Multicast_Hot_1()
46 OnNext(90, 1), in Multicast_Hot_1()
71 OnNext(270, 5) in Multicast_Hot_1()
2728 s.OnNext(1); in Replay_Default1()
2729 s.OnNext(2); in Replay_Default1()
2745 s.OnNext(1); in Replay_Default2()
2746 s.OnNext(2); in Replay_Default2()
2762 s.OnNext(1); in Replay_Default3()
2763 s.OnNext(2); in Replay_Default3()
2779 s.OnNext(1); in Replay_Default4()
[all …]
|
| H A D | ObservableStandardQueryOperatorTest.cs | 16306 xs.OnNext(0); in SelectMany_TaskWithCompletionSource_Simple_InnerCompleteBeforeOuter()
16307 xs.OnNext(1); in SelectMany_TaskWithCompletionSource_Simple_InnerCompleteBeforeOuter()
16308 xs.OnNext(2); in SelectMany_TaskWithCompletionSource_Simple_InnerCompleteBeforeOuter()
16339 xs.OnNext(0); in SelectMany_TaskWithCompletionSource_Simple_OuterCompleteBeforeInner()
16340 xs.OnNext(1); in SelectMany_TaskWithCompletionSource_Simple_OuterCompleteBeforeInner()
16341 xs.OnNext(2); in SelectMany_TaskWithCompletionSource_Simple_OuterCompleteBeforeInner()
16378 xs.OnNext(0); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_NeverInvoked()
16379 xs.OnNext(1); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_NeverInvoked()
16380 xs.OnNext(2); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_NeverInvoked()
16420 xs.OnNext(0); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_Invoked()
[all …]
|
| H A D | ObservableSingleTest.cs | 39 OnNext(150, 1), in AsObservable_AsObservable()
40 OnNext(220, 2), in AsObservable_AsObservable()
53 OnNext(220, 2), in AsObservable_AsObservable()
93 OnNext(150, 1), in AsObservable_Empty()
117 OnNext(150, 1), in AsObservable_Throw()
140 OnNext(150, 1), in AsObservable_Return()
141 OnNext(220, 2), in AsObservable_Return()
150 OnNext(220, 2), in AsObservable_Return()
210 OnNext(150, 1), in Buffer_Count_PartialWindow()
211 OnNext(210, 2), in Buffer_Count_PartialWindow()
[all …]
|
| H A D | ObservableMultipleTest.cs | 14253 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted12()
14292 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted13()
14331 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted14()
14332 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted14()
14371 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted15()
14372 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted15()
14373 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted15()
14412 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted16()
14413 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted16()
14414 …OnNext(150, 1), OnNext(210, 5), OnNext(220, 6), OnNext(230, 7), OnNext(240, 8), OnNext(250, 9), On… in Zip_AllCompleted16()
[all …]
|
| H A D | ObservableImperativeTest.cs | 53 OnNext(100, 1), in ForEachAsync_Never()
54 OnNext(200, 2), in ForEachAsync_Never()
55 OnNext(300, 3), in ForEachAsync_Never()
56 OnNext(400, 4), in ForEachAsync_Never()
57 OnNext(500, 5) in ForEachAsync_Never()
88 OnNext(100, 1), in ForEachAsync_Completed()
89 OnNext(200, 2), in ForEachAsync_Completed()
90 OnNext(300, 3), in ForEachAsync_Completed()
91 OnNext(400, 4), in ForEachAsync_Completed()
92 OnNext(500, 5), in ForEachAsync_Completed()
[all …]
|
| H A D | ObservableTimeTest.cs | 68 OnNext(100, 1), in BufferWithTime_Basic1()
69 OnNext(210, 2), in BufferWithTime_Basic1()
70 OnNext(240, 3), in BufferWithTime_Basic1()
71 OnNext(280, 4), in BufferWithTime_Basic1()
72 OnNext(320, 5), in BufferWithTime_Basic1()
73 OnNext(350, 6), in BufferWithTime_Basic1()
74 OnNext(380, 7), in BufferWithTime_Basic1()
75 OnNext(420, 8), in BufferWithTime_Basic1()
76 OnNext(470, 9), in BufferWithTime_Basic1()
904 s.OnNext(1); in Delay_TimeSpan_Real_Simple1_Impl()
[all …]
|
| H A D | ObservableExTest.cs | 36 observer.OnNext(1); in ToIterate_Complete()
39 observer.OnNext(2); in ToIterate_Complete()
55 OnNext(10, 1), in Iterate_Complete()
56 OnNext(20, 2), in Iterate_Complete()
57 OnNext(30, 3), in Iterate_Complete()
58 OnNext(40, 4), in Iterate_Complete()
63 OnNext(10, 1), in Iterate_Complete()
64 OnNext(20, 2), in Iterate_Complete()
69 OnNext(10, 1), in Iterate_Complete()
70 OnNext(20, 2), in Iterate_Complete()
[all …]
|
| H A D | ObservableAggregateTest.cs | 47 OnNext(150, 1), in AggregateWithSeed_Empty()
56 OnNext(250, 42), in AggregateWithSeed_Empty()
71 OnNext(150, 1), in AggregateWithSeed_Return()
72 OnNext(210, 24), in AggregateWithSeed_Return()
98 OnNext(150, 1), in AggregateWithSeed_Throw()
123 OnNext(150, 1) in AggregateWithSeed_Never()
146 OnNext(150, 1), in AggregateWithSeed_Range()
147 OnNext(210, 0), in AggregateWithSeed_Range()
148 OnNext(220, 1), in AggregateWithSeed_Range()
149 OnNext(230, 2), in AggregateWithSeed_Range()
[all …]
|
| H A D | ObservableConversionTests.cs | 59 OnNext(201, 1), in SubscribeToEnumerable_Finite()
60 OnNext(202, 2), in SubscribeToEnumerable_Finite()
61 OnNext(203, 3), in SubscribeToEnumerable_Finite()
62 OnNext(204, 4), in SubscribeToEnumerable_Finite()
63 OnNext(205, 5), in SubscribeToEnumerable_Finite()
88 OnNext(201, 1), in SubscribeToEnumerable_Infinite()
96 OnNext(209, 1) in SubscribeToEnumerable_Infinite()
268 src.OnNext(1); in ToEvent_NonUnit()
269 src.OnNext(2); in ToEvent_NonUnit()
273 src.OnNext(3); in ToEvent_NonUnit()
[all …]
|
| H A D | ObservableConcurrencyTest.cs | 783 s.OnNext(1); in ObserveOn_LongRunning_Simple()
784 s.OnNext(2); in ObserveOn_LongRunning_Simple()
785 s.OnNext(3); in ObserveOn_LongRunning_Simple()
807 s.OnNext(1); in ObserveOn_LongRunning_Error()
808 s.OnNext(2); in ObserveOn_LongRunning_Error()
809 s.OnNext(3); in ObserveOn_LongRunning_Error()
866 s.OnNext(1); in ObserveOn_LongRunning_HoldUpDuringDispatchAndFail()
869 s.OnNext(2); in ObserveOn_LongRunning_HoldUpDuringDispatchAndFail()
870 s.OnNext(3); in ObserveOn_LongRunning_HoldUpDuringDispatchAndFail()
898 s.OnNext(0); in ObserveOn_LongRunning_Cancel()
[all …]
|
| H A D | ObservableCreationTest.cs | 60 o.OnNext(42); in Create_NullCoalescingAction()
79 o.OnNext(1); in Create_Next()
80 o.OnNext(2); in Create_Next()
86 OnNext(200, 1), in Create_Next()
87 OnNext(200, 2) in Create_Next()
183 OnNext(900, 4) in Create_Dispose()
227 o.OnNext(42); in CreateWithDisposable_NullCoalescingAction()
399 o.OnNext(42); in CreateAsync_NullCoalescingAction1()
415 o.OnNext(42); in CreateAsync_NullCoalescingAction2()
431 o.OnNext(42); in CreateAsync_NullCoalescingDisposable1()
[all …]
|
| H A D | ObservableBlockingTest.cs | 45 OnNext(100, 1), in Chunkify_Regular1()
46 OnNext(200, 2), in Chunkify_Regular1()
47 OnNext(300, 3), in Chunkify_Regular1()
48 OnNext(400, 4), in Chunkify_Regular1()
49 OnNext(500, 5), in Chunkify_Regular1()
50 OnNext(600, 6), in Chunkify_Regular1()
51 OnNext(700, 7), in Chunkify_Regular1()
52 OnNext(800, 8), in Chunkify_Regular1()
99 OnNext(100, 1), in Chunkify_Regular2()
100 OnNext(200, 2), in Chunkify_Regular2()
[all …]
|
| H A D | ObservableAwaiterTest.cs | 40 OnNext(20, -1), in Await()
41 OnNext(150, 0), in Await()
42 OnNext(220, 1), in Await()
43 OnNext(290, 2), in Await()
44 OnNext(340, 3), in Await()
73 OnNext(20, -1), in Await_Error()
74 OnNext(150, 0), in Await_Error()
75 OnNext(220, 1), in Await_Error()
76 OnNext(290, 2), in Await_Error()
77 OnNext(340, 3), in Await_Error()
[all …]
|
| H A D | ObservableSafetyTest.cs | 54 OnNext(210, 42), in Safety_Subscription2()
55 OnNext(220, 43), in Safety_Subscription2()
56 OnNext(230, 44), in Safety_Subscription2()
57 OnNext(240, 45), in Safety_Subscription2()
174 OnNext(210, 1), in Producer_ObserverThrows()
175 OnNext(220, 2), in Producer_ObserverThrows()
176 OnNext(230, 3) in Producer_ObserverThrows()
180 OnNext(215, 1), in Producer_ObserverThrows()
182 OnNext(235, 3) in Producer_ObserverThrows()
227 OnNext(230, 3) in Producer_ObserverThrows_CustomObserver()
[all …]
|
| H A D | ObservableExtensionsTest.cs | 165 OnNext(210, 1), in Subscribe_CT_None()
166 OnNext(220, 2), in Subscribe_CT_None()
167 OnNext(230, 3), in Subscribe_CT_None()
178 OnNext(210, 1), in Subscribe_CT_None()
179 OnNext(220, 2), in Subscribe_CT_None()
180 OnNext(230, 3), in Subscribe_CT_None()
195 OnNext(210, 1), in Subscribe_CT_CancelBeforeBegin()
196 OnNext(220, 2), in Subscribe_CT_CancelBeforeBegin()
197 OnNext(230, 3), in Subscribe_CT_CancelBeforeBegin()
223 OnNext(210, 1), in Subscribe_CT_CancelMiddle()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/Subjects/ |
| H A D | ReplaySubjectTest.cs | 67 OnNext(70, 1), in Infinite()
68 OnNext(110, 2), in Infinite()
69 OnNext(220, 3), in Infinite()
70 OnNext(270, 4), in Infinite()
71 OnNext(340, 5), in Infinite()
72 OnNext(410, 6), in Infinite()
73 OnNext(520, 7), in Infinite()
113 OnNext(521, 7) in Infinite()
120 OnNext(631, 8) in Infinite()
585 s.OnNext(42); in HasObservers_OnCompleted()
[all …]
|
| H A D | BehaviorSubjectTest.cs | 39 OnNext(70, 1), in Infinite()
40 OnNext(110, 2), in Infinite()
41 OnNext(220, 3), in Infinite()
42 OnNext(270, 4), in Infinite()
419 s.OnNext(42); in HasObservers_OnCompleted()
435 s.OnNext(42); in HasObservers_OnError()
455 s.OnNext(43); in Value_First()
465 s.OnNext(43); in Value_Second()
468 s.OnNext(44); in Value_Second()
478 s.OnNext(43); in Value_FrozenAfterOnCompleted()
[all …]
|
| H A D | SubjectTest.cs | 43 OnNext(70, 1), in Infinite()
44 OnNext(110, 2), in Infinite()
45 OnNext(220, 3), in Infinite()
46 OnNext(270, 4), in Infinite()
47 OnNext(340, 5), in Infinite()
48 OnNext(410, 6), in Infinite()
49 OnNext(520, 7), in Infinite()
50 OnNext(630, 8), in Infinite()
395 s.OnNext(21); in Subject_Create()
516 s.OnNext(42); in HasObservers_OnCompleted()
[all …]
|
| H A D | AsyncSubjectTest.cs | 40 OnNext(70, 1), in Infinite()
41 OnNext(110, 2), in Infinite()
42 OnNext(220, 3), in Infinite()
43 OnNext(270, 4), in Infinite()
44 OnNext(340, 5), in Infinite()
45 OnNext(410, 6), in Infinite()
46 OnNext(520, 7), in Infinite()
47 OnNext(630, 8), in Infinite()
421 x.OnNext(42); in GetResult_Context()
517 s.OnNext(42); in HasObservers_OnCompleted()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/ |
| H A D | RegressionTest.cs | 58 OnNext(100, 1), in Bug_1283()
59 OnNext(220, 2), in Bug_1283()
60 OnNext(240, 3), in Bug_1283()
61 OnNext(300, 4), in Bug_1283()
62 OnNext(310, 5), in Bug_1283()
87 OnNext(205, 1), in Bug_1261()
88 OnNext(210, 2), in Bug_1261()
89 OnNext(215, 3), in Bug_1261()
90 OnNext(220, 4), in Bug_1261()
161 d.OnNext(e); in Bug_1333()
[all …]
|
| H A D | ConnectableObservableTest.cs | 44 OnNext(210, 1), in ConnectableObservable_Connected()
45 OnNext(220, 2), in ConnectableObservable_Connected()
46 OnNext(230, 3), in ConnectableObservable_Connected()
47 OnNext(240, 4), in ConnectableObservable_Connected()
59 OnNext(210, 1), in ConnectableObservable_Connected()
60 OnNext(220, 2), in ConnectableObservable_Connected()
61 OnNext(230, 3), in ConnectableObservable_Connected()
62 OnNext(240, 4), in ConnectableObservable_Connected()
73 OnNext(210, 1), in ConnectableObservable_NotConnected()
74 OnNext(220, 2), in ConnectableObservable_NotConnected()
[all …]
|
| H A D | ObserverTest.cs | 115 res.OnNext(42); in Create_OnNext()
311 o.OnNext(1); in Observer_Checked_AlreadyTerminated_Completed()
312 o.OnNext(2); in Observer_Checked_AlreadyTerminated_Completed()
330 o.OnNext(1); in Observer_Checked_AlreadyTerminated_Error()
331 o.OnNext(2); in Observer_Checked_AlreadyTerminated_Error()
366 o.OnNext(1); in Observer_Checked_Reentrant_Next()
469 s.OnNext(1); in Observer_Synchronize_Monitor_Reentrant1()
498 s.OnNext(1); in Observer_Synchronize_Monitor_Reentrant2()
527 s.OnNext(1); in Observer_Synchronize_Monitor_Reentrant3()
556 s.OnNext(1); in Observer_Synchronize_AsyncLock_NonReentrant1()
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/lib_rpl/rpl/ |
| H A D | producer.h | 194 OnNext &&next,
498 OnNext next;
504 OnNext next;
531 OnNext next;
538 OnNext next;
557 OnNext next;
564 OnNext next;
570 OnNext next;
578 OnNext next;
990 OnNext,
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/ |
| H A D | Average.cs | 36 public void OnNext(double value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageDouble._
104 public void OnNext(float value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageSingle._
172 public void OnNext(decimal value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageDecimal._
240 public void OnNext(int value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageInt32._
308 public void OnNext(long value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageInt64._
376 public void OnNext(double? value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageDoubleNullable._
410 base._observer.OnNext(null); in OnCompleted()
447 public void OnNext(float? value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageSingleNullable._
518 public void OnNext(decimal? value)
589 public void OnNext(int? value) in OnNext() method in System.Reactive.Linq.ObservableImpl.AverageInt32Nullable._
[all …]
|
| H A D | Sum.cs | 34 public void OnNext(double value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumDouble._
47 base._observer.OnNext(_sum); in OnCompleted()
80 public void OnNext(float value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumSingle._
126 public void OnNext(decimal value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumDecimal._
139 base._observer.OnNext(_sum); in OnCompleted()
172 public void OnNext(int value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumInt32._
196 base._observer.OnNext(_sum); in OnCompleted()
229 public void OnNext(long value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumInt64._
253 base._observer.OnNext(_sum); in OnCompleted()
427 public void OnNext(int? value) in OnNext() method in System.Reactive.Linq.ObservableImpl.SumInt32Nullable._
[all …]
|