Home
last modified time | relevance | path

Searched refs:subscription2 (Results 1 – 25 of 76) sorted by relevance

1234

/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/Subjects/
H A DReplaySubjectTest.cs88 var subscription2 = default(IDisposable); in Infinite()
102 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Infinite()
158 var subscription2 = default(IDisposable); in Infinite2()
172 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Infinite2()
226 var subscription2 = default(IDisposable); in Finite()
240 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Finite()
294 var subscription2 = default(IDisposable); in Error()
308 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Error()
353 var subscription2 = default(IDisposable); in Canceled()
367 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Canceled()
[all …]
H A DAsyncSubjectTest.cs61 var subscription2 = default(IDisposable); in Infinite()
71 scheduler.ScheduleAbsolute(400, () => subscription2 = subject.Subscribe(results2)); in Infinite()
75 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Infinite()
117 var subscription2 = default(IDisposable); in Finite()
131 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Finite()
179 var subscription2 = default(IDisposable); in Error()
193 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Error()
230 var subscription2 = default(IDisposable); in Canceled()
244 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Canceled()
273 var subscription2 = default(IDisposable); in SubjectDisposed()
[all …]
H A DBehaviorSubjectTest.cs60 var subscription2 = default(IDisposable); in Infinite()
70 scheduler.ScheduleAbsolute(400, () => subscription2 = subject.Subscribe(results2)); in Infinite()
74 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Infinite()
126 var subscription2 = default(IDisposable); in Finite()
140 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Finite()
193 var subscription2 = default(IDisposable); in Error()
207 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Error()
251 var subscription2 = default(IDisposable); in Canceled()
265 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Canceled()
296 var subscription2 = default(IDisposable); in SubjectDisposed()
[all …]
H A DSubjectTest.cs64 var subscription2 = default(IDisposable); in Infinite()
74 scheduler.ScheduleAbsolute(400, () => subscription2 = s.Subscribe(results2)); in Infinite()
78 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Infinite()
127 var subscription2 = default(IDisposable); in Finite()
141 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Finite()
192 var subscription2 = default(IDisposable); in Error()
206 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Error()
248 var subscription2 = default(IDisposable); in Canceled()
262 scheduler.ScheduleAbsolute(700, () => subscription2.Dispose()); in Canceled()
328 var subscription2 = default(IDisposable); in SubjectDisposed()
[all …]
/dports/www/moodle310/moodle/admin/tool/monitor/tests/
H A Dprivacy_test.php243 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
244 $subscription2 = $monitorgenerator->create_subscription($subscription2);
280 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
310 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
311 $subscription2 = $monitorgenerator->create_subscription($subscription2);
337 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
368 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
369 $subscription2 = $monitorgenerator->create_subscription($subscription2);
404 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
/dports/www/moodle39/moodle/admin/tool/monitor/tests/
H A Dprivacy_test.php243 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
244 $subscription2 = $monitorgenerator->create_subscription($subscription2);
280 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
310 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
311 $subscription2 = $monitorgenerator->create_subscription($subscription2);
337 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
368 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
369 $subscription2 = $monitorgenerator->create_subscription($subscription2);
404 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
/dports/www/moodle311/moodle/admin/tool/monitor/tests/
H A Dprivacy_test.php243 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
244 $subscription2 = $monitorgenerator->create_subscription($subscription2);
280 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
310 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
311 $subscription2 = $monitorgenerator->create_subscription($subscription2);
337 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
368 $subscription2 = (object)['ruleid' => $rule2->id, 'userid' => $user2->id];
369 $subscription2 = $monitorgenerator->create_subscription($subscription2);
404 $this->assertEquals($user2->id, $dbsubs[$subscription2->id]->userid);
/dports/net/libzmq4/zeromq-4.3.4/tests/
H A Dtest_xpub_manual.cpp89 const uint8_t subscription2[] = {1, 'B'}; in test_unsubscribe_manual() local
90 send_array_expect_success (sub, subscription2, 0); in test_unsubscribe_manual()
101 recv_array_expect_success (pub, subscription2, 0); in test_unsubscribe_manual()
318 const uint8_t subscription2[] = {1, static_cast<uint8_t> (topic2[0])}; in test_missing_subscriptions() local
319 recv_array_expect_success (xpub_proxy, subscription2, ZMQ_DONTWAIT); in test_missing_subscriptions()
322 send_array_expect_success (xsub_proxy, subscription2, 0); in test_missing_subscriptions()
417 const uint8_t subscription2[2] = {1, 'B'}; in test_unsubscribe_cleanup() local
418 send_array_expect_success (sub, subscription2, 0); in test_unsubscribe_cleanup()
421 recv_array_expect_success (pub, subscription2, 0); in test_unsubscribe_cleanup()
H A Dtest_xpub_manual_last_value.cpp89 const uint8_t subscription2[] = {1, 'B'}; in test_unsubscribe_manual() local
90 send_array_expect_success (sub, subscription2, 0); in test_unsubscribe_manual()
101 recv_array_expect_success (pub, subscription2, 0); in test_unsubscribe_manual()
325 const uint8_t subscription2[] = {1, static_cast<uint8_t> (topic2[0])}; in test_missing_subscriptions() local
326 recv_array_expect_success (xpub_proxy, subscription2, ZMQ_DONTWAIT); in test_missing_subscriptions()
329 send_array_expect_success (xsub_proxy, subscription2, 0); in test_missing_subscriptions()
424 const uint8_t subscription2[2] = {1, 'B'}; in test_unsubscribe_cleanup() local
425 send_array_expect_success (sub, subscription2, 0); in test_unsubscribe_cleanup()
428 recv_array_expect_success (pub, subscription2, 0); in test_unsubscribe_cleanup()
/dports/sysutils/consul/consul-1.10.3/agent/consul/state/
H A Dstore_integration_test.go74 subscription2 := &stream.SubscribeRequest{
79 sub2, err := publisher.Subscribe(subscription2)
166 subscription2 := &stream.SubscribeRequest{
171 sub, err = publisher.Subscribe(subscription2)
283 subscription2 := &stream.SubscribeRequest{
288 sub, err = publisher.Subscribe(subscription2)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/consul/state/
H A Dstore_integration_test.go74 subscription2 := &stream.SubscribeRequest{
79 sub2, err := publisher.Subscribe(subscription2)
166 subscription2 := &stream.SubscribeRequest{
171 sub, err = publisher.Subscribe(subscription2)
283 subscription2 := &stream.SubscribeRequest{
288 sub, err = publisher.Subscribe(subscription2)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/consul/state/
H A Dstore_integration_test.go74 subscription2 := &stream.SubscribeRequest{
79 sub2, err := publisher.Subscribe(subscription2)
166 subscription2 := &stream.SubscribeRequest{
171 sub, err = publisher.Subscribe(subscription2)
283 subscription2 := &stream.SubscribeRequest{
288 sub, err = publisher.Subscribe(subscription2)
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/device/battery/
H A Dbattery_status_service_unittest.cc142 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
149 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
169 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/device/battery/
H A Dbattery_status_service_unittest.cc142 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
149 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
169 std::unique_ptr<BatterySubscription> subscription2 = AddCallback(callback2()); in TEST_F() local
/dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/public/cpp/bindings/tests/
H A Dsync_handle_registry_unittest.cc36 SyncHandleRegistry::EventCallbackSubscription subscription2 = in TEST_F() local
66 SyncHandleRegistry::EventCallbackSubscription subscription2 = in TEST_F() local
95 subscription2.reset(); in TEST_F()
253 SyncHandleRegistry::EventCallbackSubscription subscription2 = in TEST_F() local
/dports/net-im/p5-Net-Jabber/Net-Jabber-2.0/t/
H A Dquery_pubsub.t40 subscription=>'subscription2'
48 testPostScalar($aff_entity2,"Subscription","subscription2");
72 …filiation2' jid='user2\@server2/resource2' node='node2' subscription='subscription2'><subscribe-op…
218 subscription=>"subscription2");
223 testPostScalar($ents_entity2,"Subscription","subscription2");
225 …filiation2' jid='user2\@server2/resource2' node='node2' subscription='subscription2'/></entities><…
235 …filiation2' jid='user2\@server2/resource2' node='node2' subscription='subscription2'/></entities>"…
244 …filiation2' jid='user2\@server2/resource2' node='node2' subscription='subscription2'/>","ents_enti…
281 subscription=>"subscription2");
286 testPostScalar($entity2,"Subscription","subscription2");
[all …]
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/langtools/jdk/jshell/
H A DShutdownTest.java75 Subscription subscription2 = getState().onShutdown(listener2); in testTwoShutdownListeners() local
87 getState().unsubscribe(subscription2); in testTwoShutdownListeners()
/dports/devel/py-rx1/Rx-1.6.1/rx/linq/observable/
H A Dsequenceequal.py100 subscription2 = second.subscribe(on_next2, observer.on_error, on_completed2)
101 return CompositeDisposable(subscription1, subscription2)

1234