We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4552053 commit c0dde4cCopy full SHA for c0dde4c
README.md
@@ -72,11 +72,11 @@ public class ExampleClient {
72
RSocket client = RSocketFactory.connect().keepAlive().transport(ws).start().block();
73
74
try {
75
- Flux<Payload> s = client.requestStream(DefaultPayload.textPayload("peace"));
+ Flux<Payload> s = client.requestStream(DefaultPayload.create("peace"));
76
77
s.take(10).doOnNext(p -> System.out.println(p.getDataUtf8())).blockLast();
78
} finally {
79
- client.close().block();
+ client.dispose();
80
}
81
82
0 commit comments