diff --git a/lib/frame/frame.dart b/lib/frame/frame.dart
index 7080970..66a08d9 100644
--- a/lib/frame/frame.dart
+++ b/lib/frame/frame.dart
@@ -38,7 +38,7 @@ RSocketFrame? parseFrame(RSocketByteBuffer byteBuffer) {
       frame = RequestFNFFrame.fromBuffer(header, byteBuffer);
       break;
     case frame_types.REQUEST_STREAM:
-      frame = RequestFNFFrame.fromBuffer(header, byteBuffer);
+      frame = RequestStreamFrame.fromBuffer(header, byteBuffer);
       break;
     case frame_types.REQUEST_CHANNEL:
       frame = RequestChannelFrame.fromBuffer(header, byteBuffer);