Skip to content

Commit e851db5

Browse files
committed
add requestStream
1 parent bfbb76f commit e851db5

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

rsocket_client.dart

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,9 @@ void main() async {
66
await RSocketConnector.create().connect('tcp://127.0.0.1:42252');
77
var result = await rsocket.requestResponse(Payload.fromText('Ping', ''));
88
print(result.getDataUtf8());
9+
/* rsocket.requestStream(Payload.fromText('Ping', '')).listen((payload) {
10+
print(payload.getDataUtf8());
11+
}, onDone: () {
12+
print('done');
13+
});*/
914
}

0 commit comments

Comments
 (0)