|
void | SetInput (BlockingCollection< object > newInput) |
| Set the input on this IPipeable to param input Should only be used internally by Connect. More...
|
|
void | Connect (IPipeable other) |
| Connect the input of other to our output Note: mirror == false using this override. More...
|
|
void | Connect (IPipeable other, bool mirror) |
| Connect the input of other to our output and allow for control of mirror data. More...
|
|
virtual void | Start (TaskFactory taskFactory, CancellationTokenSource cts) |
| Actually start doing work (i.e., promise to eventually start pushing data to connected pipeables) More...
|
|
virtual void | Stop () |
| Require this IPipeable to stop, blocking until actually stopped. More...
|
|
|
void | Add (object item) |
|
abstract bool | Process (object item) |
|
void SharpBCI.Pipeable.Add |
( |
object |
item | ) |
|
|
protected |
void SharpBCI.Pipeable.Connect |
( |
IPipeable |
other | ) |
|
Connect the input of other to our output Note: mirror == false using this override.
Implements SharpBCI.IPipeable.
void SharpBCI.Pipeable.Connect |
( |
IPipeable |
other, |
|
|
bool |
mirror |
|
) |
| |
Connect the input of other to our output and allow for control of mirror data.
Implements SharpBCI.IPipeable.
abstract bool SharpBCI.Pipeable.Process |
( |
object |
item | ) |
|
|
protectedpure virtual |
void SharpBCI.Pipeable.SetInput |
( |
BlockingCollection< object > |
input | ) |
|
virtual void SharpBCI.Pipeable.Start |
( |
TaskFactory |
taskFactory, |
|
|
CancellationTokenSource |
cts |
|
) |
| |
|
virtual |
virtual void SharpBCI.Pipeable.Stop |
( |
| ) |
|
|
virtual |
const int SharpBCI.Pipeable.DEFAULT_BUFFER_SIZE = 1000 |
The documentation for this class was generated from the following file:
- /home/travis/build/berkona/SharpBCI/SharpBCI/Pipeline.cs