reactor.core.processor.spec

Class ProcessorSpec<T>

java.lang.Object

reactor.core.processor.spec.ProcessorSpec<T>

All Implemented Interfaces:

Supplier<Processor<T>>

public class ProcessorSpec<T>
extends java.lang.Object
implements Supplier<Processor<T>>

Specification class to create Processors.

Constructor Summary

Constructors

Constructor and Description
ProcessorSpec()

Method Summary

Modifier and Type	Method and Description
ProcessorSpec<T>	blockingWaitStrategy() Set BlockingWaitStrategy as wait strategy.
ProcessorSpec<T>	busySpinWaitStrategy() Set BusySpinWaitStrategy as wait strategy.
ProcessorSpec<T>	consume(Consumer<T> consumer) When data is mutated and published into the Processor, invoke the given Consumer and pass the mutated data.
ProcessorSpec<T>	dataBufferSize(int dataBufferSize) How many data objects to pre-allocate in the buffer.
ProcessorSpec<T>	dataSupplier(Supplier<T> dataSupplier) Use the given Supplier to provide new instances of the data object for pre-allocation.
Processor<T>	get() Get an object.
ProcessorSpec<T>	multiThreadedProducer() Protect against publication of data events from multiple producer threads.
ProcessorSpec<T>	singleThreadedProducer() Optimize for highest throughput by assuming only a single thread will be publishing data events into this Processor.
ProcessorSpec<T>	sleepingWaitStrategy() Set SleepingWaitStrategy as wait strategy.
ProcessorSpec<T>	waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy) Set Disruptor's WaitStrategy.
ProcessorSpec<T>	when(java.lang.Class<? extends java.lang.Throwable> type, Consumer<java.lang.Throwable> errorConsumer) Assign the given Consumer as an error handler for exceptions of the given type.
ProcessorSpec<T>	yieldingWaitStrategy() Set YieldingWaitStrategy as wait strategy.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProcessorSpec

public ProcessorSpec()

Method Detail

multiThreadedProducer

public ProcessorSpec<T> multiThreadedProducer()

Protect against publication of data events from multiple producer threads.

Returns:

this

singleThreadedProducer

public ProcessorSpec<T> singleThreadedProducer()

Optimize for highest throughput by assuming only a single thread will be publishing data events into this Processor.

Returns:

this

dataBufferSize

public ProcessorSpec<T> dataBufferSize(int dataBufferSize)

How many data objects to pre-allocate in the buffer.

Parameters:

dataBufferSize - number of data objects to pre-allocate

Returns:

this

dataSupplier

public ProcessorSpec<T> dataSupplier(Supplier<T> dataSupplier)

Use the given Supplier to provide new instances of the data object for pre-allocation.

Parameters:

dataSupplier - the Supplier to provide new data instances

Returns:

this

waitStrategy

public ProcessorSpec<T> waitStrategy(com.lmax.disruptor.WaitStrategy waitStrategy)

Set Disruptor's WaitStrategy.

Parameters:

waitStrategy - the WaitStrategy to use

Returns:

this

blockingWaitStrategy

public ProcessorSpec<T> blockingWaitStrategy()

Set BlockingWaitStrategy as wait strategy.

Returns:

this

sleepingWaitStrategy

public ProcessorSpec<T> sleepingWaitStrategy()

Set SleepingWaitStrategy as wait strategy.

Returns:

this

yieldingWaitStrategy

public ProcessorSpec<T> yieldingWaitStrategy()

Set YieldingWaitStrategy as wait strategy.

Returns:

this

busySpinWaitStrategy

public ProcessorSpec<T> busySpinWaitStrategy()

Set BusySpinWaitStrategy as wait strategy.

Returns:

this

consume

public ProcessorSpec<T> consume(Consumer<T> consumer)

When data is mutated and published into the Processor, invoke the given Consumer and pass the mutated data.

Parameters:

consumer - the mutated event data Consumer

Returns:

this

when

public ProcessorSpec<T> when(java.lang.Class<? extends java.lang.Throwable> type,
                             Consumer<java.lang.Throwable> errorConsumer)

Assign the given Consumer as an error handler for exceptions of the given type.

Parameters:

type - type of the exception to handle

errorConsumer - exception Consumer

Returns:

this

get

public Processor<T> get()

Description copied from interface: Supplier

Get an object.

Specified by:

get in interface Supplier<Processor<T>>

Returns:

An object.