StreamChannelController<T> class

A controller for exposing a new StreamChannel.

This exposes two connected StreamChannels, local and foreign. The user's code should use local to emit and receive events. Then foreign can be returned for others to use. For example, here's a simplified version of the implementation of IsolateChannel.new:

StreamChannel isolateChannel(ReceivePort receivePort, SendPort sendPort) {
  var controller = new StreamChannelController(allowForeignErrors: false);

  // Pipe all events from the receive port into the local sink...
  receivePort.pipe(controller.local.sink);

  // ...and all events from the local stream into the send port.
  controller.local.stream.listen(sendPort.send, onDone: receivePort.close);

  // Then return the foreign controller for your users to use.
  return controller.foreign;
}