| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/ |
| H A D | ObservableMultipleTest.cs | 157 OnCompleted<int>(225) in Amb_NeverEmpty()
165 OnCompleted<int>(225) in Amb_NeverEmpty()
188 OnCompleted<int>(225) in Amb_EmptyNever()
196 OnCompleted<int>(225) in Amb_EmptyNever()
216 OnCompleted<int>(240) in Amb_RegularShouldDisposeLoser()
222 OnCompleted<int>(250) in Amb_RegularShouldDisposeLoser()
231 OnCompleted<int>(240) in Amb_RegularShouldDisposeLoser()
259 OnCompleted<int>(250) in Amb_WinnerThrows()
296 OnCompleted<int>(250) in Amb_LoserThrows()
8502 xs.OnCompleted(); in Merge_TaskWithCompletionSource_InnerCompleteBeforeOuter()
[all …]
|
| H A D | ObservableAggregateTest.cs | 48 OnCompleted<int>(250) in AggregateWithSeed_Empty()
57 OnCompleted<int>(250) in AggregateWithSeed_Empty()
73 OnCompleted<int>(250) in AggregateWithSeed_Return()
82 OnCompleted<int>(250) in AggregateWithSeed_Return()
152 OnCompleted<int>(260) in AggregateWithSeed_Range()
161 OnCompleted<int>(260) in AggregateWithSeed_Range()
183 OnCompleted<int>(260) in AggregateWithSeed_AccumulatorThrows()
206 OnCompleted<int>(250) in AggregateWithSeedAndResult_Empty()
215 OnCompleted<int>(250) in AggregateWithSeedAndResult_Empty()
231 OnCompleted<int>(250) in AggregateWithSeedAndResult_Return()
[all …]
|
| H A D | ObservableExTest.cs | 43 observer.OnCompleted(); in ToIterate_Complete()
59 OnCompleted<int>(50) in Iterate_Complete()
65 OnCompleted<int>(30) in Iterate_Complete()
74 OnCompleted<int>(60) in Iterate_Complete()
83 OnCompleted<int>(280) in Iterate_Complete()
123 OnCompleted<int>(50) in Iterate_Complete_Implicit()
129 OnCompleted<int>(30) in Iterate_Complete_Implicit()
138 OnCompleted<int>(60) in Iterate_Complete_Implicit()
180 observer.OnCompleted(); in ToIterate_Throw()
193 OnCompleted<int>(50) in Iterate_Iterator_Throw()
[all …]
|
| H A D | ObservableImperativeTest.cs | 93 OnCompleted<int>(600) in ForEachAsync_Completed()
170 OnCompleted<int>(600) in ForEachAsync_Throw()
211 OnCompleted<int>(600) in ForEachAsync_CancelDuring()
246 OnCompleted<int>(600) in ForEachAsync_CancelBefore()
279 OnCompleted<int>(600) in ForEachAsync_CancelAfter()
505 OnCompleted<int>(300) in Case_One()
512 OnCompleted<int>(310) in Case_One()
519 OnCompleted<int>(320) in Case_One()
534 OnCompleted<int>(300) in Case_One()
557 OnCompleted<int>(300) in Case_Two()
[all …]
|
| H A D | ObservableSingleTest.cs | 41 OnCompleted<int>(250) in AsObservable_AsObservable()
54 OnCompleted<int>(250) in AsObservable_AsObservable()
94 OnCompleted<int>(250) in AsObservable_Empty()
102 OnCompleted<int>(250) in AsObservable_Empty()
142 OnCompleted<int>(250) in AsObservable_Return()
151 OnCompleted<int>(250) in AsObservable_Return()
215 OnCompleted<int>(250) in Buffer_Count_PartialWindow()
243 OnCompleted<int>(250) in Buffer_Count_FullWindows()
272 OnCompleted<int>(250) in Buffer_Count_FullAndPartialWindows()
330 OnCompleted<int>(250) in Buffer_Count_Skip_Less()
[all …]
|
| H A D | ObservableStandardQueryOperatorTest.cs | 142 OnCompleted<B>(300) in Cast_Complete()
16313 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_Simple_InnerCompleteBeforeOuter()
16342 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_Simple_OuterCompleteBeforeInner()
16381 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_NeverInvoked()
16426 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_Invoked()
16526 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_Simple_Cancellation_AfterSelectorThrows()
16704 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_WithResultSelector_InnerCompleteBeforeOuter()
16733 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_WithResultSelector_OuterCompleteBeforeInner()
16772 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_WithResultSelector_Cancellation_NeverInvoked()
16817 xs.OnCompleted(); in SelectMany_TaskWithCompletionSource_WithResultSelector_Cancellation_Invoked()
[all …]
|
| H A D | ObservableTimeTest.cs | 77 OnCompleted<int>(600) in BufferWithTime_Basic1()
114 OnCompleted<int>(600) in BufferWithTime_Basic2()
187 OnCompleted<int>(600) in BufferWithTime_Disposed()
219 OnCompleted<int>(600) in BufferWithTime_Basic_Same()
254 OnCompleted<int>(600) in BufferWithTime_Basic_Same_Periodic()
351 OnCompleted<int>(600) in BufferWithTimeOrCount_Basic()
428 OnCompleted<int>(600) in BufferWithTimeOrCount_Disposed()
495 OnCompleted<int>(550) in Delay_TimeSpan_Simple1_Impl()
506 OnCompleted<int>(650) in Delay_TimeSpan_Simple1_Impl()
907 s.OnCompleted(); in Delay_TimeSpan_Real_Simple1_Impl()
[all …]
|
| H A D | ObservableJoinsTest.cs | 72 OnCompleted<int>(220) in And2()
137 OnCompleted<int>(220) in And3()
202 OnCompleted<int>(220) in And4()
268 OnCompleted<int>(220) in And5()
333 OnCompleted<int>(220) in And6()
398 OnCompleted<int>(220) in And7()
463 OnCompleted<int>(220) in And8()
528 OnCompleted<int>(220) in And9()
593 OnCompleted<int>(220) in And10()
658 OnCompleted<int>(220) in And11()
[all …]
|
| H A D | ObservableAwaiterTest.cs | 31 …ows<ArgumentNullException>(() => Observable.GetAwaiter(Observable.Empty<int>()).OnCompleted(null)); in Await_ArgumentChecking()
45 OnCompleted<int>(410) in Await()
53 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; result = aw… in Await()
85 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; ReactiveAss… in Await_Error()
114 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; awaiter.Get… in Await_Never()
132 OnCompleted<int>(300) in Await_Empty()
139 …scheduler.ScheduleAbsolute(200, () => awaiter.OnCompleted(() => { t = scheduler.Clock; ReactiveAss… in Await_Empty()
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Joins/ |
| H A D | ActivePlan.cs | 45 if (n1.Kind == NotificationKind.OnCompleted) in Match()
82 if ( n1.Kind == NotificationKind.OnCompleted in Match()
83 || n2.Kind == NotificationKind.OnCompleted) in Match()
126 if ( n1.Kind == NotificationKind.OnCompleted in Match()
127 || n2.Kind == NotificationKind.OnCompleted in Match()
128 || n3.Kind == NotificationKind.OnCompleted) in Match()
177 if ( n1.Kind == NotificationKind.OnCompleted in Match()
178 || n2.Kind == NotificationKind.OnCompleted in Match()
179 || n3.Kind == NotificationKind.OnCompleted in Match()
237 if ( n1.Kind == NotificationKind.OnCompleted in Match()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/ |
| H A D | Sum.cs | 45 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumDouble._
48 base._observer.OnCompleted(); in OnCompleted()
91 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumSingle._
137 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumDecimal._
194 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumInt32._
251 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumInt64._
298 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumDoubleNullable._
345 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumSingleNullable._
392 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumDecimalNullable._
450 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SumInt32Nullable._
[all …]
|
| H A D | Min.cs | 87 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Min.Delta
153 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Min._
212 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinDouble._
279 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinSingle._
346 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinDecimal._
413 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinInt32._
480 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinInt64._
547 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinDoubleNullable._
606 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinSingleNullable._
665 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MinDecimalNullable._
[all …]
|
| H A D | Max.cs | 87 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Max.Delta
153 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Max._
212 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxDouble._
279 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxSingle._
346 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxDecimal._
413 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxInt32._
480 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxInt64._
547 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxDoubleNullable._
606 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxSingleNullable._
665 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.MaxDecimalNullable._
[all …]
|
| H A D | Average.cs | 59 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageDouble._
64 base._observer.OnCompleted(); in OnCompleted()
127 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageSingle._
195 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageDecimal._
263 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageInt32._
331 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageInt64._
402 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageDoubleNullable._
473 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageSingleNullable._
544 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageDecimalNullable._
615 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.AverageInt32Nullable._
[all …]
|
| H A D | Window.cs | 124 s.OnCompleted(); in OnNext()
144 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Window._
251 s.OnCompleted(); in Tick()
286 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Window.WindowImpl
291 s.OnCompleted(); in OnCompleted()
362 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Window.TimeShiftImpl
433 _s.OnCompleted(); in Tick()
479 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Window.BoundedWindowImpl
483 _s.OnCompleted(); in OnCompleted()
645 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Window._
[all …]
|
| H A D | SequenceEqual.cs | 108 _parent._observer.OnCompleted(); in OnNext()
115 _parent._observer.OnCompleted(); in OnNext()
129 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SequenceEqual._.F
139 _parent._observer.OnCompleted(); in OnCompleted()
145 _parent._observer.OnCompleted(); in OnCompleted()
183 _parent._observer.OnCompleted(); in OnNext()
190 _parent._observer.OnCompleted(); in OnNext()
204 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SequenceEqual._.S
289 base._observer.OnCompleted(); in OnNext()
300 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SequenceEqual.SequenceEqualImpl
[all …]
|
| H A D | Any.cs | 50 base._observer.OnCompleted(); in OnNext()
60 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Any._
63 base._observer.OnCompleted(); in OnCompleted()
95 base._observer.OnCompleted(); in OnNext()
106 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Any.AnyImpl
109 base._observer.OnCompleted(); in OnCompleted()
|
| H A D | SelectMany.cs | 174 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany._
326 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.IndexSelectorImpl
494 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.NoSelectorImpl
580 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.Omega
710 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.SelectManyImpl
847 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.Sigma
1055 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany._
1244 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.IndexSelectorImpl
1423 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.NoSelectorImpl
1506 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.SelectMany.Omega
[all …]
|
| H A D | Merge.cs | 108 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Merge._
122 base._observer.OnCompleted(); in OnCompleted()
158 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Merge._.Iter
172 _parent._observer.OnCompleted(); in OnCompleted()
235 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Merge.MergeConcurrent
242 base._observer.OnCompleted(); in OnCompleted()
285 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Merge.MergeConcurrent.Iter
300 _parent._observer.OnCompleted(); in OnCompleted()
354 OnCompleted(); in OnCompletedTask()
387 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Merge.MergeImpl
[all …]
|
| H A D | FirstAsync.cs | 50 base._observer.OnCompleted(); in OnNext()
60 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.FirstAsync._
69 base._observer.OnCompleted(); in OnCompleted()
104 base._observer.OnCompleted(); in OnNext()
115 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.FirstAsync.FirstAsyncImpl
124 base._observer.OnCompleted(); in OnCompleted()
|
| H A D | TakeWhile.cs | 75 base._observer.OnCompleted(); in OnNext()
87 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.TakeWhile._
89 base._observer.OnCompleted(); in OnCompleted()
129 base._observer.OnCompleted(); in OnNext()
141 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.TakeWhile.TakeWhileImpl
143 base._observer.OnCompleted(); in OnCompleted()
|
| H A D | Catch.cs | 56 public override void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Catch._
58 base._observer.OnCompleted(); in OnCompleted()
67 base._observer.OnCompleted(); in Done()
148 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Catch._
150 base._observer.OnCompleted(); in OnCompleted()
174 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.ObservableImpl.Catch._.Impl
176 _parent._observer.OnCompleted(); in OnCompleted()
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Experimental/Reactive/Linq/ |
| H A D | QueryLanguageEx.cs | 170 case NotificationKind.OnCompleted: in ForkJoin()
175 observer.OnCompleted(); in ForkJoin()
177 observer.OnCompleted(); in ForkJoin()
191 observer.OnCompleted(); in ForkJoin()
209 case NotificationKind.OnCompleted: in ForkJoin()
214 observer.OnCompleted(); in ForkJoin()
216 observer.OnCompleted(); in ForkJoin()
253 subscriber.OnCompleted(); in ForkJoin()
368 chain.OnCompleted(); in ManySelect()
396 public void OnCompleted() in OnCompleted() method in System.Reactive.Linq.QueryLanguageEx.ChainObservable
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Subjects/ |
| H A D | AsyncSubject.cs | 52 public void OnCompleted() in OnCompleted() method in System.Reactive.Subjects.AsyncSubject
79 o.OnCompleted(); in OnCompleted()
84 o.OnCompleted(); in OnCompleted()
170 observer.OnCompleted(); in Subscribe()
173 observer.OnCompleted(); in Subscribe()
240 public void OnCompleted(Action continuation) in OnCompleted() method in System.Reactive.Subjects.AsyncSubject
245 OnCompleted(continuation, true); in OnCompleted()
249 private void OnCompleted(Action continuation, bool originalContext) in OnCompleted() method in System.Reactive.Subjects.AsyncSubject
276 public void OnCompleted() in OnCompleted() method in System.Reactive.Subjects.AsyncSubject.AwaitObserver
334 OnCompleted(() => e.Set(), false); in GetResult()
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Core/Reactive/Internal/ |
| H A D | Observers.cs | 9 public void OnCompleted() in OnCompleted() method in System.Reactive.NopObserver
28 public void OnCompleted() in OnCompleted() method in System.Reactive.DoneObserver
45 public void OnCompleted() in OnCompleted() method in System.Reactive.DisposedObserver
70 public void OnCompleted() in OnCompleted() method in System.Reactive.Observer
73 observer.OnCompleted(); in OnCompleted()
|