Searched refs:subscribe (Results 1 – 4 of 4) sorted by relevance
276 p.subscribe(s); in testSubscribe1()287 p.subscribe(s2); in testSubscribe1()310 p.subscribe(s); in testSubscribe2()328 p.subscribe(s); in testSubscribe3()341 p.subscribe(s); in testSubscribe4()351 p.subscribe(s); in testSubscribe4()365 p.subscribe(s); in testSubscribe5()378 p.subscribe(null); in testSubscribe6()391 p.subscribe(s1); in testCloseCompletes()392 p.subscribe(s2); in testCloseCompletes()[all …]
208 public void subscribe(Subscriber<? super T> subscriber); in subscribe() method
342 public void subscribe(Subscriber<? super T> subscriber) { in subscribe() method in SubmissionPublisher925 subscribe(new ConsumerSubscriber<T>(status, consumer)); in consume()
15952 method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);16333 method public void subscribe(java.util.concurrent.Flow.Subscriber<? super T>);