File tree Expand file tree Collapse file tree
rsocket-core/src/main/java/io/rsocket/core Expand file tree Collapse file tree Original file line number Diff line number Diff line change 6161 * <pre>{@code
6262 * import io.rsocket.transport.netty.client.TcpClientTransport;
6363 *
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);
6667 * }</pre>
6768 *
6869 * <p>To customize connection settings before connecting:
6970 *
7071 * <pre>{@code
71- * RSocketClient client =
72+ * Mono<RSocket> source =
7273 * RSocketConnector.create()
7374 * .metadataMimeType("message/x.rsocket.composite-metadata.v0")
7475 * .dataMimeType("application/cbor")
75- * .toRSocketClient(TcpClientTransport.create("localhost", 7000));
76+ * .connect(TcpClientTransport.create("localhost", 7000));
77+ * RSocketClient client = RSocketClient.from(source);
7678 * }</pre>
7779 */
7880public class RSocketConnector {
@@ -112,7 +114,7 @@ public static RSocketConnector create() {
112114 * Static factory method to connect with default settings, effectively a shortcut for:
113115 *
114116 * <pre class="code">
115- * RSocketConnector.create().connectWith (transport);
117+ * RSocketConnector.create().connect (transport);
116118 * </pre>
117119 *
118120 * @param transport the transport of choice to connect with
You can’t perform that action at this time.
0 commit comments