parseFrames function

Iterable<RSocketFrame> parseFrames(List<int> chunk)

Implementation

Iterable<RSocketFrame> parseFrames(List<int> chunk) sync* {
  var byteBuffer = RSocketByteBuffer.fromArray(chunk);
  while (byteBuffer.isReadable()) {
    var frame = parseFrame(byteBuffer);
    if (frame != null) {
      yield frame;
    }
  }
}