File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed
rsocket-core/src/main/java/io/rsocket Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change 4
4
import reactor .core .publisher .Flux ;
5
5
6
6
/**
7
- * Extends the {@link RSocket} that allows an implementor to peek at the first request payload of a channel.
7
+ * Extends the {@link RSocket} that allows an implementer to peek at the first request payload of a
8
+ * channel.
8
9
*/
9
10
public interface RequestHandler extends RSocket {
10
11
/**
11
- * Implement this method to peak at the first payload of the incoming request stream
12
- * @param payload First payload in the stream
12
+ * Implement this method to peak at the first payload of the incoming request stream without
13
+ * having to subscribe to Publish<Payload> payloads
14
+ *
15
+ * @param payload First payload in the stream - this is the same payload as the first payload in
16
+ * Publisher<Payload> payloads
13
17
* @param payloads Stream of request payloads.
14
18
* @return Stream of response payloads.
15
19
*/
You can’t perform that action at this time.
0 commit comments