Home
last modified time | relevance | path

Searched refs:Subscribe (Results 1 – 25 of 4168) sorted by relevance

12345678910>>...167

/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/
H A DObservableExtensionsTest.cs24 #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 DObservableAggregateTest.cs61 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 DObservableSingleTest.cs58 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 DObservableTimeTest.cs3522 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 DObservableBindingTest.cs75 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 DObservableStandardQueryOperatorTest.cs146 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 DObservable.Extensions.cs15 #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 DReplaySubjectTest.cs474 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 DSubjectTest.cs70 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 DAsyncSubjectTest.cs67 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 DBehaviorSubjectTest.cs66 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 DFormEditor.Sound.cs61 .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 Dfeed_test.go39 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 DBinders.cs21 .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 DHandleViewModel.cs67 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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 Dpublisher_test.go11 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(),

12345678910>>...167