encodeChannelFrame static method

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

Implementation

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