public class Streams extends Object
| Constructor and Description |
|---|
Streams() |
| Modifier and Type | Method and Description |
|---|---|
static void |
connect(CommandStream inStream,
PushStream outStream,
CommandVisitor visitor)
Attach the visitor as a handle to the inStream and propagate
the done signal from the inStream to the outStream
|
static CommandStream |
map(CommandStream inStream,
EmitterVisitor emitterVisitor)
Attach the emitting visitor to the inStream.
|
public static void connect(CommandStream inStream, PushStream outStream, CommandVisitor visitor)
inStream - - the input streamoutStream - - the output streamvisitor - - a command visitorpublic static CommandStream map(CommandStream inStream, EmitterVisitor emitterVisitor)
inStream - - the input streamemitterVisitor - - the emitter visitorCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.