LineBasedFrameConn constructor

LineBasedFrameConn({
  1. required Socket socket,
  2. required dynamic onReadFrame,
  3. required dynamic onError,
  4. required dynamic onDone,
})

Implementation

LineBasedFrameConn(
    {required this.socket,
    required onReadFrame,
    required onError,
    required onDone}) {
  socket.listen((List<int> list) async {
    /// Stick the TCP package
    while (true) {
      List<int> data = ReadFrame(list);
      if (data.isEmpty) {
        return;
      }
      if (onReadFrame != null) {
        await onReadFrame(data, this);
      }
      list = List.empty();
    }
  }, onDone: onDone, onError: onError);
}