connect method

void connect(
  1. NetworkerPipe<O, dynamic> pipe
)

Implementation

void connect(NetworkerPipe<O, dynamic> pipe) {
  _pipes[pipe] = pipe._writeController.stream.listen(_sendMessagePacket);
}