reactor.core.action

Interface Pipeline<T>

All Superinterfaces:

Flushable<T>

All Known Implementing Classes:

Composable, Promise, Stream

public interface Pipeline<T>
extends Flushable<T>

Component that can be injected with Actions and consume flush events for releasing buffer owned by the pipeline

Since:

1.1

Field Summary

Fields inherited from interface reactor.core.action.Flushable

FLUSH_EVENT

Method Summary

Modifier and Type	Method and Description
Pipeline<T>	add(Action<T> action) Consume events with the passed Action
Pipeline<T>	consumeFlush(Flushable<?> action) Consume flush with the passed Flushable

Methods inherited from interface reactor.core.action.Flushable

flush

Method Detail

add

Pipeline<T> add(Action<T> action)

Consume events with the passed Action

Parameters:

action - the action listening for values

consumeFlush

Pipeline<T> consumeFlush(Flushable<?> action)

Consume flush with the passed Flushable

Parameters:

action - the action listening for flush

Returns:

this