encodeRequestStreamFrame static method

Uint8List encodeRequestStreamFrame(
  1. int streamId,
  2. int initialRequestN,
  3. Payload payload
)

Implementation

static Uint8List encodeRequestStreamFrame(
    int streamId, int initialRequestN, Payload payload) {
  var frameBuffer = RSocketByteBuffer();
  frameBuffer.writeI24(0); // frame length
  frameBuffer.writeI32(streamId); //stream id
  writeTFrameTypeAndFlags(
      frameBuffer, frame_types.REQUEST_STREAM, payload.metadata, 0);
  frameBuffer.writeI32(initialRequestN);
  writePayload(frameBuffer, payload);
  refillFrameLength(frameBuffer);
  return frameBuffer.toUint8Array();
}