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 java.lang.Exception
Publisher chain.subscription - the upstream subscriptiondownstream - the downstream to write tojava.lang.Exception - any error in establishing the mapping