Package com.tnsai.coordination.streaming

Class StreamingChannel.Builder<T>

java.lang.Object

com.tnsai.coordination.streaming.StreamingChannel.Builder<T>

Enclosing class:

StreamingChannel<T>

public static class StreamingChannel.Builder<T>
extends Object

Method Summary

Modifier and Type	Method	Description
StreamingChannel.Builder<T>	backpressure(BackpressureStrategy strategy)
StreamingChannel.Builder<T>	bufferSize(int size)
StreamingChannel<T>	build()
StreamingChannel.Builder<T>	id(String id)
StreamingChannel.Builder<T>	offerTimeout(Duration timeout)

Methods inherited from class java.lang.Object

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

Method Details

id

public StreamingChannel.Builder<T> id(String id)

bufferSize

public StreamingChannel.Builder<T> bufferSize(int size)

backpressure

public StreamingChannel.Builder<T> backpressure(BackpressureStrategy strategy)

offerTimeout

public StreamingChannel.Builder<T> offerTimeout(Duration timeout)

build

public StreamingChannel<T> build()