/dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/Tests.System.Reactive/Tests/Linq/Subjects/ |
H A D | ReplaySubjectTest.cs | 88 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 D | AsyncSubjectTest.cs | 61 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 D | BehaviorSubjectTest.cs | 60 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 D | SubjectTest.cs | 64 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 D | privacy_test.php | 243 $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 D | privacy_test.php | 243 $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 D | privacy_test.php | 243 $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 D | test_xpub_manual.cpp | 89 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 D | test_xpub_manual_last_value.cpp | 89 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 D | store_integration_test.go | 74 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 D | store_integration_test.go | 74 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 D | store_integration_test.go | 74 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 D | battery_status_service_unittest.cc | 142 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 D | battery_status_service_unittest.cc | 142 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 D | sync_handle_registry_unittest.cc | 36 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 D | query_pubsub.t | 40 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | ShutdownTest.java | 75 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 D | sequenceequal.py | 100 subscription2 = second.subscribe(on_next2, observer.on_error, on_completed2) 101 return CompositeDisposable(subscription1, subscription2)
|