U
- the type of item emitted from upstreamD
- the type of item to emit downstream (i.e. post transform)public interface StreamMapper<U,D>
Streams.streamMap(Publisher, StreamMapper)
Modifier and Type | Method and Description |
---|---|
WriteStream<U> |
map(Subscription subscription,
WriteStream<D> downstream)
A transform step in a
Publisher chain. |
WriteStream<U> map(Subscription subscription, WriteStream<D> downstream) throws Exception
Publisher
chain.subscription
- the upstream subscriptiondownstream
- the downstream to write toException
- any error in establishing the mapping