Searched refs:subscription (Results 1 – 2 of 2) sorted by relevance
348 BufferedSubscription<T> subscription = in subscribe() local360 subscription.onSubscribe(); in subscribe()362 subscription.onError(ex); in subscribe()364 subscription.onComplete(); in subscribe()366 clients = subscription; in subscribe()368 pred.next = subscription; in subscribe()933 Subscription subscription; field in SubmissionPublisher.ConsumerSubscriber938 public final void onSubscribe(Subscription subscription) { in onSubscribe() argument939 this.subscription = subscription; in onSubscribe()940 status.whenComplete((v, e) -> subscription.cancel()); in onSubscribe()[all …]
230 public void onSubscribe(Subscription subscription); in onSubscribe() argument