| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/Subjects/ |
| H A D | ReplaySubjectTest.cs | 85 var subscription1 = default(IDisposable); in Infinite()
101 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Infinite()
103 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Infinite()
155 var subscription1 = default(IDisposable); in Infinite2()
171 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Infinite2()
173 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Infinite2()
223 var subscription1 = default(IDisposable); in Finite()
239 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Finite()
291 var subscription1 = default(IDisposable); in Error()
350 var subscription1 = default(IDisposable); in Canceled()
[all …]
|
| H A D | AsyncSubjectTest.cs | 58 var subscription1 = default(IDisposable); in Infinite()
74 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Infinite()
76 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Infinite()
114 var subscription1 = default(IDisposable); in Finite()
130 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Finite()
132 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Finite()
176 var subscription1 = default(IDisposable); in Error()
192 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Error()
194 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Error()
227 var subscription1 = default(IDisposable); in Canceled()
[all …]
|
| H A D | BehaviorSubjectTest.cs | 57 var subscription1 = default(IDisposable); in Infinite()
73 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Infinite()
75 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Infinite()
123 var subscription1 = default(IDisposable); in Finite()
139 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Finite()
141 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Finite()
190 var subscription1 = default(IDisposable); in Error()
206 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Error()
208 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Error()
248 var subscription1 = default(IDisposable); in Canceled()
[all …]
|
| H A D | SubjectTest.cs | 61 var subscription1 = default(IDisposable); in Infinite()
77 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Infinite()
79 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Infinite()
124 var subscription1 = default(IDisposable); in Finite()
140 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Finite()
142 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Finite()
189 var subscription1 = default(IDisposable); in Error()
205 scheduler.ScheduleAbsolute(600, () => subscription1.Dispose()); in Error()
207 scheduler.ScheduleAbsolute(800, () => subscription1.Dispose()); in Error()
245 var subscription1 = default(IDisposable); in Canceled()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/device/battery/ |
| H A D | battery_status_service_unittest.cc | 126 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
129 subscription1.reset(); in TEST_F()
135 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
148 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
168 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
177 subscription1.reset(); in TEST_F()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/device/battery/ |
| H A D | battery_status_service_unittest.cc | 126 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
129 subscription1.reset(); in TEST_F()
135 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
148 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
168 std::unique_ptr<BatterySubscription> subscription1 = AddCallback(callback1()); in TEST_F() local
177 subscription1.reset(); in TEST_F()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/media/router/providers/cast/ |
| H A D | cast_app_discovery_service_unittest.cc | 90 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
117 subscription1.reset(); in TEST_F()
125 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
143 subscription1.reset(); in TEST_F()
148 subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F()
152 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
179 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
233 auto subscription1 = app_discovery_service_->StartObservingMediaSinks( in TEST_F() local
253 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
291 auto subscription1 = StartObservingMediaSinksInitially(source_a_1_); in TEST_F() local
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/sender/ |
| H A D | cast_app_discovery_service_impl_unittest.cc | 102 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
118 subscription1.Reset(); in TEST_F()
130 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
138 subscription1.Reset(); in TEST_F()
143 subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F()
152 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
174 auto subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F() local
241 auto subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F() local
290 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
311 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/sender/ |
| H A D | cast_app_discovery_service_impl_unittest.cc | 102 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
118 subscription1.Reset(); in TEST_F()
130 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
138 subscription1.Reset(); in TEST_F()
143 subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F()
152 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
174 auto subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F() local
241 auto subscription1 = StartObservingAvailability(source_a_1_, &receivers1); in TEST_F() local
290 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
311 auto subscription1 = StartSourceA1Query(&receivers1, &request_id, &sender_id); in TEST_F() local
|
| /dports/net/libzmq4/zeromq-4.3.4/tests/ |
| H A D | test_xpub_manual.cpp | 85 const uint8_t subscription1[] = {1, 'A'}; in test_unsubscribe_manual() local
86 send_array_expect_success (sub, subscription1, 0); in test_unsubscribe_manual()
95 recv_array_expect_success (pub, subscription1, 0); in test_unsubscribe_manual()
304 const uint8_t subscription1[] = {1, static_cast<uint8_t> (topic1[0])}; in test_missing_subscriptions() local
305 recv_array_expect_success (xpub_proxy, subscription1, ZMQ_DONTWAIT); in test_missing_subscriptions()
308 send_array_expect_success (xsub_proxy, subscription1, 0); in test_missing_subscriptions()
381 const uint8_t subscription1[2] = {1, 'A'}; in test_unsubscribe_cleanup() local
382 send_array_expect_success (sub, subscription1, 0); in test_unsubscribe_cleanup()
386 recv_array_expect_success (pub, subscription1, 0); in test_unsubscribe_cleanup()
|
| H A D | test_xpub_manual_last_value.cpp | 85 const uint8_t subscription1[] = {1, 'A'}; in test_unsubscribe_manual() local
86 send_array_expect_success (sub, subscription1, 0); in test_unsubscribe_manual()
95 recv_array_expect_success (pub, subscription1, 0); in test_unsubscribe_manual()
310 const uint8_t subscription1[] = {1, static_cast<uint8_t> (topic1[0])}; in test_missing_subscriptions() local
311 recv_array_expect_success (xpub_proxy, subscription1, ZMQ_DONTWAIT); in test_missing_subscriptions()
314 send_array_expect_success (xsub_proxy, subscription1, 0); in test_missing_subscriptions()
388 const uint8_t subscription1[2] = {1, 'A'}; in test_unsubscribe_cleanup() local
389 send_array_expect_success (sub, subscription1, 0); in test_unsubscribe_cleanup()
393 recv_array_expect_success (pub, subscription1, 0); in test_unsubscribe_cleanup()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/public/cpp/bindings/tests/ |
| H A D | sync_handle_registry_unittest.cc | 34 SyncHandleRegistry::EventCallbackSubscription subscription1 = in TEST_F() local
44 subscription1.reset(); in TEST_F()
62 SyncHandleRegistry::EventCallbackSubscription subscription1 = in TEST_F() local
75 &subscription1, &called2)); in TEST_F()
218 SyncHandleRegistry::EventCallbackSubscription subscription1 = in TEST_F() local
251 &e1, &subscription1, registry(), &called2); in TEST_F()
|
| /dports/net-im/p5-Net-Jabber/Net-Jabber-2.0/t/ |
| H A D | query_pubsub.t | 29 testScalar($aff_entity1,"Subscription","subscription1");
35 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'><subscribe-op…
70 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'><subscribe-op…
211 testScalar($ents_entity1,"Subscription","subscription1");
213 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'/></entities><…
235 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'/><entity affi…
243 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'/>","ents_enti…
268 testScalar($entity1,"Subscription","subscription1");
270 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'/></pubsub>", …
276 …filiation1' jid='user1\@server1/resource1' node='node1' subscription='subscription1'><subscribe-op…
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| H A D | SnippetStatusListenerTest.java | 52 Subscription subscription1 = getState().onSnippetEvent(listener1); in testTwoSnippetEventListeners() local
65 getState().unsubscribe(subscription1); in testTwoSnippetEventListeners()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/langtools/jdk/jshell/ |
| H A D | ShutdownTest.java | 74 Subscription subscription1 = getState().onShutdown(listener1); in testTwoShutdownListeners() local
76 getState().unsubscribe(subscription1); in testTwoShutdownListeners()
|
| /dports/devel/py-rx1/Rx-1.6.1/rx/linq/observable/ |
| H A D | sequenceequal.py | 99 subscription1 = first.subscribe(on_next1, observer.on_error, on_completed1)
101 return CompositeDisposable(subscription1, subscription2)
|
| /dports/devel/py-rx/Rx-3.2.0/rx/core/operators/ |
| H A D | sequenceequal.py | 102 subscription1 = first.subscribe_(on_next1, observer.on_error, on_completed1, scheduler)
104 return CompositeDisposable(subscription1, subscription2)
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsub/ |
| H A D | README.md | 37 // Use a callback to receive messages via subscription1.
38 sub := client.Subscription("subscription1")
|