Searched refs:activeSink (Results 1 – 1 of 1) sorted by relevance
162 private final AtomicReference<EventSink> activeSink = new AtomicReference<>(null); field in EventChannel.IncomingStreamRequestHandler182 final EventSink oldSink = activeSink.getAndSet(eventSink); in onListen()196 activeSink.set(null); in onListen()203 final EventSink oldSink = activeSink.getAndSet(null); in onCancel()223 if (hasEnded.get() || activeSink.get() != this) { in success()232 if (hasEnded.get() || activeSink.get() != this) { in error()243 if (hasEnded.getAndSet(true) || activeSink.get() != this) { in endOfStream()