com.exoreaction.xorcery.reactivestreams.util (xorcery-project 0.40.1-SNAPSHOT API)

package com.exoreaction.xorcery.reactivestreams.util

Class

Description

FutureProcessor<T>

Processor that tracks the state of the stream with a CompletableFuture.

ReactiveStreams

SubscriberConfiguration

TypeConverterProcessor<P,S>

Processor that converts items from one type to another using specified MessageWriter/MessageReader.