Struct DisruptorBuilder 

pub struct DisruptorBuilder<T, F> { /* private fields */ }

Implementations

impl<T, F> DisruptorBuilder<T, F>

where F: Fn() -> T,

pub fn new(factory: F) -> Self

Creates a new builder with the given factory.

pub fn buffer_size(self, size: usize) -> Self

Sets the buffer size.

pub fn wait_strategy<W: WaitStrategy + 'static>(self, strategy: W) -> Self

Sets the wait strategy.

pub fn single_producer(self) -> Self

Sets the producer type to Single.

pub fn multi_producer(self) -> Self

Sets the producer type to Multi.

pub fn build(self) -> Disruptor<T>

Builds the Disruptor.