static <E> void |
RingBufferSubscriberUtils.onComplete(com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <E> void |
RingBufferSubscriberUtils.onError(Throwable error,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <E> void |
RingBufferSubscriberUtils.onNext(E value,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <T> boolean |
RingBufferSubscriberUtils.waitRequestOrTerminalEvent(com.lmax.disruptor.Sequence pendingRequest,
com.lmax.disruptor.RingBuffer<MutableSignal<T>> ringBuffer,
com.lmax.disruptor.SequenceBarrier barrier,
org.reactivestreams.Subscriber<? super T> subscriber,
AtomicBoolean isRunning) |
static <E> org.reactivestreams.Publisher<Void> |
RingBufferSubscriberUtils.writeWith(org.reactivestreams.Publisher<? extends E> source,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |