@@ -68,6 +68,21 @@ static RSocketRequester.Builder builder() {
6868 return new DefaultRSocketRequesterBuilder ();
6969 }
7070
71+ // For now we treat metadata as a simple string that is the route.
72+ // This will change after the resolution of:
73+ // https://github.com/rsocket/rsocket-java/issues/568
74+
75+ /**
76+ * Entry point to prepare a new request to the given route.
77+ *
78+ * <p>For requestChannel interactions, i.e. Flux-to-Flux the metadata is
79+ * attached to the first request payload.
80+ *
81+ * @param route the routing destination
82+ * @return a spec for further defining and executing the reuqest
83+ */
84+ RequestSpec route (String route );
85+
7186 /**
7287 * A mutable builder for creating a client {@link RSocketRequester}.
7388 */
@@ -90,15 +105,15 @@ RSocketRequester.Builder rsocketFactory(
90105
91106 /**
92107 * Configure the {@code ClientTransport} for the RSocket connection
93- * and connect to the RSocket server
108+ * and connect to the RSocket server.
94109 * @param transport the chosen client transport
95110 * @return a mono containing the connected {@code RSocketRequester}
96111 */
97112 Mono <RSocketRequester > connect (ClientTransport transport , MimeType dataMimeType );
98113
99114 /**
100115 * Connect to the RSocket server over TCP transport using the
101- * provided connection parameters
116+ * provided connection parameters.
102117 * @param host the RSocket server host
103118 * @param port the RSocket server port
104119 * @param dataMimeType the data MimeType
@@ -108,7 +123,7 @@ RSocketRequester.Builder rsocketFactory(
108123
109124 /**
110125 * Connect to the RSocket server over WebSocket transport using the
111- * provided connection parameters
126+ * provided connection parameters.
112127 * @param uri the RSocket server endpoint URI
113128 * @param dataMimeType the data MimeType
114129 * @return a mono containing the connected {@code RSocketRequester}
@@ -117,21 +132,6 @@ RSocketRequester.Builder rsocketFactory(
117132
118133 }
119134
120- // For now we treat metadata as a simple string that is the route.
121- // This will change after the resolution of:
122- // https://github.com/rsocket/rsocket-java/issues/568
123-
124- /**
125- * Entry point to prepare a new request to the given route.
126- *
127- * <p>For requestChannel interactions, i.e. Flux-to-Flux the metadata is
128- * attached to the first request payload.
129- *
130- * @param route the routing destination
131- * @return a spec for further defining and executing the reuqest
132- */
133- RequestSpec route (String route );
134-
135135
136136 /**
137137 * Contract to provide input data for an RSocket request.
0 commit comments