File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed
rsocket-core/src/main/java/io/rsocket/core Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change 61
61
* <pre>{@code
62
62
* import io.rsocket.transport.netty.client.TcpClientTransport;
63
63
*
64
- * RSocketClient client =
65
- * RSocketConnector.createRSocketClient(TcpClientTransport.create("localhost", 7000));
64
+ * Mono<RSocket> source =
65
+ * RSocketConnector.connectWith(TcpClientTransport.create("localhost", 7000));
66
+ * RSocketClient client = RSocketClient.from(source);
66
67
* }</pre>
67
68
*
68
69
* <p>To customize connection settings before connecting:
69
70
*
70
71
* <pre>{@code
71
- * RSocketClient client =
72
+ * Mono<RSocket> source =
72
73
* RSocketConnector.create()
73
74
* .metadataMimeType("message/x.rsocket.composite-metadata.v0")
74
75
* .dataMimeType("application/cbor")
75
- * .toRSocketClient(TcpClientTransport.create("localhost", 7000));
76
+ * .connect(TcpClientTransport.create("localhost", 7000));
77
+ * RSocketClient client = RSocketClient.from(source);
76
78
* }</pre>
77
79
*/
78
80
public class RSocketConnector {
@@ -112,7 +114,7 @@ public static RSocketConnector create() {
112
114
* Static factory method to connect with default settings, effectively a shortcut for:
113
115
*
114
116
* <pre class="code">
115
- * RSocketConnector.create().connectWith (transport);
117
+ * RSocketConnector.create().connect (transport);
116
118
* </pre>
117
119
*
118
120
* @param transport the transport of choice to connect with
You can’t perform that action at this time.
0 commit comments