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 28cc17e commit a7cb3d2Copy full SHA for a7cb3d2
src/main/java/io/reactivesocket/util/ReactiveSocketProxy.java
@@ -69,7 +69,6 @@ public Publisher<Payload> requestStream(Payload payload) {
69
child.requestStream(payload).subscribe(subscriber);
70
};
71
}
72
-
73
74
75
@Override
@@ -82,7 +81,6 @@ public Publisher<Payload> requestSubscription(Payload payload) {
82
81
child.requestSubscription(payload).subscribe(subscriber);
83
84
85
86
87
88
@@ -95,7 +93,6 @@ public Publisher<Payload> requestChannel(Publisher<Payload> payloads) {
95
93
child.requestChannel(payloads).subscribe(subscriber);
96
94
97
98
99
100
101
0 commit comments