Interface Stage.ProcessorStage

All Superinterfaces:
Stage
Enclosing interface:
Stage

public static interface Stage.ProcessorStage extends Stage
A processor stage.

When built, must connect upstream of the graph to the inlet of this processor, and downstream to the outlet.

  • Method Details

    • getRsProcessor

      org.reactivestreams.Processor<?,?> getRsProcessor()
      The processor.
      Returns:
      The processor.