public final class RingBufferSubscriberUtils extends Object
Subscriber
handling when the
signals are stored in a RingBuffer
.Modifier and Type | Method and Description |
---|---|
static <E> void |
onComplete(com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <E> void |
onError(Throwable error,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <E> void |
onNext(E value,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
static <E> void |
route(MutableSignal<E> task,
org.reactivestreams.Subscriber<? super E> subscriber) |
static <E> void |
routeOnce(MutableSignal<E> task,
org.reactivestreams.Subscriber<? super E> subscriber) |
static <T> boolean |
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> |
writeWith(org.reactivestreams.Publisher<? extends E> source,
com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer) |
public static <E> void onNext(E value, com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer)
public static <E> void onError(Throwable error, com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer)
public static <E> void onComplete(com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer)
public static <E> void route(MutableSignal<E> task, org.reactivestreams.Subscriber<? super E> subscriber)
public static <E> void routeOnce(MutableSignal<E> task, org.reactivestreams.Subscriber<? super E> subscriber)
public static <T> boolean 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)
public static <E> org.reactivestreams.Publisher<Void> writeWith(org.reactivestreams.Publisher<? extends E> source, com.lmax.disruptor.RingBuffer<MutableSignal<E>> ringBuffer)
Copyright © 2016. All rights reserved.