reactor.core.action

Interface Flushable<T>

All Known Subinterfaces:

Pipeline<T>

All Known Implementing Classes:

BufferAction, CollectAction, Composable, ConnectAction, CountAction, ForEachAction, MovingWindowAction, Promise, ReduceAction, Stream, SupplyAction, WindowAction

public interface Flushable<T>

Component that can be flushed

Since:

1.1

Field Summary

Fields

Modifier and Type	Field and Description
static Event<java.lang.Object>	FLUSH_EVENT

Method Summary

Modifier and Type	Method and Description
Flushable<T>	flush() Trigger flush on this component, generally draining any collected values.

Field Detail

FLUSH_EVENT

static final Event<java.lang.Object> FLUSH_EVENT

Method Detail

flush

Flushable<T> flush()

Trigger flush on this component, generally draining any collected values.