/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/ |
H A D | ObservableExtensionsTest.cs | 24 #region Subscribe 53 Observable.Return(1, Scheduler.Immediate).Subscribe(); in Subscribe_None_Return() 63 ReactiveAssert.Throws(ex, () => xs.Subscribe()); in Subscribe_None_Throw() 126 #region Subscribe with CancellationToken 244 Subscribe(200, 225) in Subscribe_CT_CancelMiddle() 327 xs.Subscribe(cts.Token); in Subscribe_CT_Overloads_AlreadyCancelled() 328 xs.Subscribe(_ => { }, cts.Token); in Subscribe_CT_Overloads_AlreadyCancelled() 329 xs.Subscribe(_ => { }, ex => { }, cts.Token); in Subscribe_CT_Overloads_AlreadyCancelled() 330 xs.Subscribe(_ => { }, () => { }, cts.Token); in Subscribe_CT_Overloads_AlreadyCancelled() 349 xs.Subscribe(CancellationToken.None); in Subscribe_CT_Overloads_None() [all …]
|
H A D | ObservableAggregateTest.cs | 61 Subscribe(200, 250) in AggregateWithSeed_Empty() 86 Subscribe(200, 250) in AggregateWithSeed_Return() 111 Subscribe(200, 210) in AggregateWithSeed_Throw() 134 Subscribe(200, 1000) in AggregateWithSeed_Never() 165 Subscribe(200, 260) in AggregateWithSeed_Range() 195 Subscribe(200, 240) in AggregateWithSeed_AccumulatorThrows() 219 Subscribe(200, 250) in AggregateWithSeedAndResult_Empty() 244 Subscribe(200, 250) in AggregateWithSeedAndResult_Return() 353 Subscribe(200, 240) in AggregateWithSeedAndResult_AccumulatorThrows() 383 Subscribe(200, 260) in AggregateWithSeedAndResult_ResultSelectorThrows() [all …]
|
H A D | ObservableSingleTest.cs | 58 Subscribe(200, 250) in AsObservable_AsObservable() 106 Subscribe(200, 250) in AsObservable_Empty() 130 Subscribe(200, 250) in AsObservable_Throw() 155 Subscribe(200, 250) in AsObservable_Return() 173 ).Subscribe(obs); in AsObservable_IsNotEager() 228 Subscribe(200, 250) in Buffer_Count_PartialWindow() 257 Subscribe(200, 250) in Buffer_Count_FullWindows() 286 Subscribe(200, 250) in Buffer_Count_FullAndPartialWindows() 315 Subscribe(200, 250) in Buffer_Count_Error() 346 Subscribe(200, 250) in Buffer_Count_Skip_Less() [all …]
|
H A D | ObservableTimeTest.cs | 3522 res.Subscribe( in Skip_Default() 3744 res.Subscribe( in SkipLast_Default1() 3764 res.Subscribe( in SkipLast_Default2() 3784 res.Subscribe( in SkipLast_Default3() 3804 res.Subscribe( in SkipLast_Default4() 4026 res.Subscribe( in SkipUntil_Default() 4253 res.Subscribe( in Take_Default() 4767 res.Subscribe( in TakeLast_Default1() 4787 res.Subscribe( in TakeLast_Default2() 4807 res.Subscribe( in TakeLast_Default3() [all …]
|
H A D | ObservableBindingTest.cs | 75 Subscribe(200, 390) in Multicast_Hot_1() 117 Subscribe(100, 390) in Multicast_Hot_2() 162 Subscribe(100, 300), in Multicast_Hot_3() 163 Subscribe(335, 390) in Multicast_Hot_3() 210 Subscribe(100, 300), in Multicast_Hot_4() 211 Subscribe(335, 390) in Multicast_Hot_4() 252 Subscribe(100, 390) in Multicast_Hot_5() 291 Subscribe(100, 390) in Multicast_Hot_6() 326 Subscribe(200, 390) in Multicast_Cold_Completed() 363 Subscribe(200, 390) in Multicast_Cold_Error() [all …]
|
H A D | ObservableStandardQueryOperatorTest.cs | 146 Subscribe(200, 300) in Cast_Complete() 178 Subscribe(200, 300) in Cast_Error() 207 Subscribe(200, 250) in Cast_Dispose() 237 Subscribe(200, 250) in Cast_NotValid() 274 Subscribe(200, 420) in DefaultIfEmpty_NonEmpty1() 300 Subscribe(200, 420) in DefaultIfEmpty_NonEmpty2() 323 Subscribe(200, 420) in DefaultIfEmpty_Empty1() 346 Subscribe(200, 420) in DefaultIfEmpty_Empty2() 370 Subscribe(200, 420) in DefaultIfEmpty_Throw1() 10466 }).Subscribe(res); in Select_DisposeInsideSelector() [all …]
|
/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Core/ |
H A D | Observable.Extensions.cs | 15 #region Subscribe delegate-based overloads 25 public static IDisposable Subscribe<T>(this IObservable<T> source) in Subscribe() method in System.ObservableExtensions 44 public static IDisposable Subscribe<T>(this IObservable<T> source, Action<T> onNext) in Subscribe() method in System.ObservableExtensions 54 … return source.Subscribe/*Unsafe*/(new AnonymousObserver<T>(onNext, Stubs.Throw, Stubs.Nop)); in Subscribe() 78 return source.Subscribe/*Unsafe*/(new AnonymousObserver<T>(onNext, onError, Stubs.Nop)); in Subscribe() 134 #region Subscribe overloads with CancellationToken 163 public static void Subscribe<T>(this IObservable<T> source, CancellationToken token) in Subscribe() method in System.ObservableExtensions 266 var d = source.Subscribe/*Unsafe*/( in Subscribe_() 285 source.Subscribe(observer); in Subscribe_() 316 return source.Subscribe(observer); in SubscribeSafe() [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 | 474 scheduler.ScheduleAbsolute(200, () => xs.Subscribe(subject)); in ReplaySubjectDiesOut() 476 scheduler.ScheduleAbsolute(300, () => subject.Subscribe(results1)); in ReplaySubjectDiesOut() 477 scheduler.ScheduleAbsolute(400, () => subject.Subscribe(results2)); in ReplaySubjectDiesOut() 478 scheduler.ScheduleAbsolute(600, () => subject.Subscribe(results3)); in ReplaySubjectDiesOut() 515 var d1 = s.Subscribe(_ => { }); in HasObservers() 521 var d2 = s.Subscribe(_ => { }); in HasObservers() 524 var d3 = s.Subscribe(_ => { }); in HasObservers() 540 var d = s.Subscribe(_ => { }); in HasObservers_Dispose1() 556 var d = s.Subscribe(_ => { }); in HasObservers_Dispose2() 582 var d = s.Subscribe(_ => { }); in HasObservers_OnCompleted() [all …]
|
H A D | SubjectTest.cs | 70 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(s)); in Infinite() 133 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(s)); in Finite() 198 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(s)); in Error() 392 s.Subscribe(x => _x = x); in Subject_Create() 446 var d1 = s.Subscribe(_ => { }); in HasObservers() 452 var d2 = s.Subscribe(_ => { }); in HasObservers() 455 var d3 = s.Subscribe(_ => { }); in HasObservers() 471 var d = s.Subscribe(_ => { }); in HasObservers_Dispose1() 487 var d = s.Subscribe(_ => { }); in HasObservers_Dispose2() 513 var d = s.Subscribe(_ => { }); in HasObservers_OnCompleted() [all …]
|
H A D | AsyncSubjectTest.cs | 67 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Infinite() 123 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Finite() 185 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Error() 236 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Canceled() 447 var d1 = s.Subscribe(_ => { }); in HasObservers() 453 var d2 = s.Subscribe(_ => { }); in HasObservers() 456 var d3 = s.Subscribe(_ => { }); in HasObservers() 472 var d = s.Subscribe(_ => { }); in HasObservers_Dispose1() 488 var d = s.Subscribe(_ => { }); in HasObservers_Dispose2() 514 var d = s.Subscribe(_ => { }); in HasObservers_OnCompleted() [all …]
|
H A D | BehaviorSubjectTest.cs | 66 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Infinite() 132 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Finite() 199 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Error() 257 scheduler.ScheduleAbsolute(200, () => subscription = xs.Subscribe(subject)); in Canceled() 349 var d1 = s.Subscribe(_ => { }); in HasObservers() 355 var d2 = s.Subscribe(_ => { }); in HasObservers() 358 var d3 = s.Subscribe(_ => { }); in HasObservers() 374 var d = s.Subscribe(_ => { }); in HasObservers_Dispose1() 390 var d = s.Subscribe(_ => { }); in HasObservers_Dispose2() 416 var d = s.Subscribe(_ => { }); in HasObservers_OnCompleted() [all …]
|
/dports/games/openbve/OpenBVE-1.8.2.1/source/TrainEditor2/Views/ |
H A D | FormEditor.Sound.cs | 61 .Subscribe(y => in BindToSound() 70 .Subscribe(y => in BindToSound() 83 .Subscribe(_ => in BindToSound() 92 .Subscribe(y => in BindToSound() 101 .Subscribe(y => in BindToSound() 114 .Subscribe(_ => in BindToSound() 139 .Subscribe(y => in BindToSound() 175 .Subscribe(y => in BindToSound() 186 .Subscribe(y => in BindToSound() 197 .Subscribe(y => in BindToSound() [all …]
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/event/ |
H A D | feed_test.go | 39 f.Subscribe(ch) 133 sub1 = feed.Subscribe(ch) 134 sub2 = feed.Subscribe(ch) 135 _ = feed.Subscribe(ch) 181 feed.Subscribe(ch1) 190 sub2 := feed.Subscribe(ch2) 246 sub1 = feed.Subscribe(ch1) 247 sub2 = feed.Subscribe(ch2) 283 sub1 = feed.Subscribe(ch1) 284 sub2 = feed.Subscribe(ch1) [all …]
|
/dports/games/openbve/OpenBVE-1.8.2.1/source/TrainEditor2/Extensions/ |
H A D | Binders.cs | 21 .Subscribe(_ => button.Enabled = command.CanExecute()) in BindToButton() 29 .Subscribe(_ => command.Execute()) in BindToButton() 53 .Subscribe(_ => in BindToButton() 72 .Subscribe(_ => button.Enabled = command.CanExecute()) in BindToButton() 80 .Subscribe(_ => command.Execute()) in BindToButton() 93 .Subscribe(_ => button.Enabled = command.CanExecute()) in BindToButton() 101 .Subscribe(_ => command.Execute(value)) in BindToButton() 114 .Subscribe(_ => button.Enabled = command.CanExecute()) in BindToButton() 122 .Subscribe(_ => command.Execute()) in BindToButton() 143 .Subscribe(_ => command.Execute(value)) in BindToButton() [all …]
|
/dports/games/openbve/OpenBVE-1.8.2.1/source/TrainEditor2/ViewModels/Trains/ |
H A D | HandleViewModel.cs | 67 PowerNotches.Subscribe(_ => train.ApplyPowerNotchesToCar()).AddTo(disposable); in HandleViewModel() 82 BrakeNotches.Subscribe(_ => train.ApplyBrakeNotchesToCar()).AddTo(disposable); in HandleViewModel() 100 LocoBrakeNotches.Subscribe(_ => train.ApplyLocoBrakeNotchesToCar()).AddTo(disposable); in HandleViewModel() 120 .Subscribe(_ => DriverPowerNotches.ForceValidate()) in HandleViewModel() 127 .Subscribe(_ => PowerNotches.ForceNotify()) in HandleViewModel() 140 .Subscribe(_ => DriverBrakeNotches.ForceValidate()) in HandleViewModel() 147 .Subscribe(_ => BrakeNotches.ForceNotify()) in HandleViewModel() 160 .Subscribe(_ => PowerNotches.ForceValidate()) in HandleViewModel() 167 .Subscribe(_ => DriverPowerNotches.ForceNotify()) in HandleViewModel() 180 .Subscribe(_ => BrakeNotches.ForceValidate()) in HandleViewModel() [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/pkg/pubsub/ |
H A D | publisher_test.go | 11 c := p.Subscribe() 24 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 38 s1 := p.Subscribe() 39 s2 := p.Subscribe() 56 subs = append(subs, p.Subscribe(), p.Subscribe(), p.Subscribe()) 79 dataCh: p.Subscribe(),
|