Package | Description |
---|---|
com.levigo.jadice.server.core | |
com.levigo.jadice.server.nodes | |
com.levigo.jadice.server.nodes.worker | |
com.levigo.jadice.server.shared.types.internal |
Modifier and Type | Class and Description |
---|---|
class |
BufferedStreamBundle
Extends StreamBundle for usage of BufferManager and BufferManagerDynamicPipe
|
Modifier and Type | Method and Description |
---|---|
StreamBundle |
NodeWorker.getInputBundle()
Get the input stream bundle.
|
StreamBundle |
NodeWorker.getOutputBundle()
Returns the output stream bundle
|
Modifier and Type | Method and Description |
---|---|
List<StreamBundle> |
NodeWorker.getInputBundles()
Get the list of input stream bundles.
|
List<StreamBundle> |
NodeWorker.getOutputBundles()
Get the list of output bundles.
|
Modifier and Type | Method and Description |
---|---|
void |
NodeWorker.addInputBundle(StreamBundle inputBundle)
Set the input stream bundle
|
void |
NodeWorker.addOutputBundle(StreamBundle sb)
Set the output stream bundle
|
SubPipeline |
SubPipeline.endWith(Node lastChild,
StreamBundle output)
The sub pipeline shall end at the given
Node and shall provide its processed data through the
given StreamBundle . |
SubPipeline |
SubPipeline.startWith(StreamBundle input,
Node firstChild)
The sub pipeline shall start at the given
Node and will be feed with data through the
given StreamBundle . |
Modifier and Type | Method and Description |
---|---|
StreamBundle |
StreamOutputNode.getStreamBundle() |
StreamBundle |
StreamInputNode.getStreamBundle()
Get the
Stream s that the client has sent. |
Modifier and Type | Method and Description |
---|---|
StreamBundle |
StreamScriptContext.process(List<Stream> s,
Node inputNode,
Node outputNode) |
StreamBundle |
StreamScriptContext.process(Node inputNode,
Node outputNode)
Execute the sub-pipeline defined by the input and output node and return the result as a
StreamBundle . |
StreamBundle |
StreamScriptContext.process(Stream s,
Node inputNode,
Node outputNode) |
Modifier and Type | Class and Description |
---|---|
class |
com.levigo.jadice.server.shared.types.internal.DefaultStreamBundle
Default implementation for
StreamBundle |
Copyright © 2017 levigo holding gmbh. All rights reserved.