Skip to content

Commit 1eb02b3

Browse files
authored
Add FrameCodec.encodeCancelFrame
1 parent f22d98d commit 1eb02b3

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

lib/frame/frame.dart

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -472,6 +472,16 @@ class FrameCodec {
472472
refillFrameLength(frameBuffer);
473473
return frameBuffer.toUint8Array();
474474
}
475+
476+
static Uint8List encodeCancelFrame(int streamId) {
477+
var frameBuffer = RSocketByteBuffer();
478+
frameBuffer.writeI24(0); // frame length
479+
frameBuffer.writeI32(streamId); //stream id
480+
frameBuffer.writeI8(frame_types.CANCEL << 2);
481+
frameBuffer.writeI8(0);
482+
refillFrameLength(frameBuffer);
483+
return frameBuffer.toUint8Array();
484+
}
475485
}
476486

477487
Payload decodePayload(

0 commit comments

Comments
 (0)