Package | Description |
---|---|
reactor.core.processor |
This package offers a suite of asynchronous
Processor with backpressure support. |
Modifier and Type | Method and Description |
---|---|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create()
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(boolean autoCancel)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service,
boolean autoCancel)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service,
int bufferSize)
Create a new RingBufferProcessor using passed backlog size, blockingWait Strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, blockingWait Strategy
and the auto-cancel argument.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(ExecutorService service,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and auto-cancel settings.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(String name,
int bufferSize)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(String name,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using the blockingWait Strategy, passed backlog size,
and auto-cancel settings.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.create(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and auto-cancel settings.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share()
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(boolean autoCancel)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service,
boolean autoCancel)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service,
int bufferSize)
Create a new RingBufferProcessor using passed backlog size, blockingWait Strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, blockingWait Strategy
and the auto-cancel argument.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(ExecutorService service,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and auto-cancel settings.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(String name,
int bufferSize)
Create a new RingBufferProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(String name,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using the blockingWait Strategy, passed backlog size,
and auto-cancel settings.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and will auto-cancel.
|
static <E> RingBufferProcessor<E> |
RingBufferProcessor.share(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferProcessor using passed backlog size, wait strategy
and auto-cancel settings.
|
Copyright © 2017. All rights reserved.