Incorrect FrameType for handling RequestStream Frame.

[DXTkastb]

Expected Behavior

Should receive message stream from dart client

Actual Behavior

Received error :

type 'RequestFNFFrame' is not a subtype of type 'RequestStreamFrame' in type cast
#0      RSocketRequester.receiveFrame (package:rsocket/core/rsocket_requester.dart:290:40)
#1      RSocketRequester.receiveChunk (package:rsocket/core/rsocket_requester.dart:205:9)

Steps to Reproduce

Dart Client (Responder) :

List<int> list = 'this is client response!'.codeUnits;
Uint8List data = Uint8List.fromList(list);

RSocketConnector connector = RSocketConnector.create().acceptor(requestStreamAcceptor((payload) {
	List<Payload> randomPayloadList = [Payload.from(null, data)];
        return Stream.fromIterable(randomPayloadList);
}));

var rsocket = await connector.connect("ws://localhost:7000/rsocket");

Spring Server (Requester):

 rsocketRequester.route("").data("this is server reqeust!")
                .retrieveFlux(String.class).subscribe((v) -> {
                   System.out.println(v);
             });

Possible Solution

rsocket-dart/lib/frame/frame.dart

Lines 40 to 42 in f31cc6e

	case frame_types.REQUEST_STREAM:
	frame = RequestFNFFrame.fromBuffer(header, byteBuffer);
	break;

should be replaced with :

    case frame_types.REQUEST_STREAM:
      frame = RequestStreamFrame.fromBuffer(header, byteBuffer);  // correct frame
      break;

• RSocket version(s) used: 1.0.0
• java : openjdk 17.0.5
• Spring Boot Server