An end-point consumer which emits TrainedEvents it received Must only be connected to Pipeables which output TrainedEvents.
More...
|
| | TrainedEventEmitter (SharpBCI self) |
| |
| 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...
|
| |
An end-point consumer which emits TrainedEvents it received Must only be connected to Pipeables which output TrainedEvents.