List? handleInput()

in lib/src/message_grouper_state.dart [22:40]


  List<int>? handleInput(int byte) {
    if (!_lengthReader.done) {
      _lengthReader.readByte(byte);
      if (_lengthReader.done) {
        _messageReader = _MessageReader(_lengthReader.length);
      }
    } else {
      assert(_messageReader != null);
      _messageReader!.readByte(byte);
    }

    if (_lengthReader.done && _messageReader!.done) {
      var message = _messageReader!.message;
      reset();
      return message;
    }

    return null;
  }