Skip to content

Commit b3565e1

Browse files
rstoyanchevOlegDokuka
authored andcommitted
Remove deprecated method in ClientRSocketFactory (#701)
I just discovered the BiConsumer vs the SocketAcceptor variants confuse the compiler with lambda syntax. The deprecation shouldn't be necessary anymore. Signed-off-by: Rossen Stoyanchev <[email protected]>
1 parent e82b535 commit b3565e1

File tree

1 file changed

+1
-12
lines changed

1 file changed

+1
-12
lines changed

rsocket-core/src/main/java/io/rsocket/RSocketFactory.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@
4444
import io.rsocket.util.MultiSubscriberRSocket;
4545
import java.time.Duration;
4646
import java.util.Objects;
47-
import java.util.function.BiFunction;
4847
import java.util.function.Consumer;
4948
import java.util.function.Function;
5049
import java.util.function.Supplier;
@@ -277,17 +276,7 @@ public ClientTransportAcceptor acceptor(Function<RSocket, RSocket> acceptor) {
277276
}
278277

279278
public ClientTransportAcceptor acceptor(Supplier<Function<RSocket, RSocket>> acceptor) {
280-
return acceptor(
281-
(SocketAcceptor)
282-
(setup, sendingSocket) -> Mono.just(acceptor.get().apply(sendingSocket)));
283-
}
284-
285-
@Deprecated
286-
public ClientTransportAcceptor acceptor(
287-
BiFunction<ConnectionSetupPayload, RSocket, RSocket> biAcceptor) {
288-
return acceptor(
289-
(SocketAcceptor)
290-
(setup, sendingSocket) -> Mono.just(biAcceptor.apply(setup, sendingSocket)));
279+
return acceptor((setup, sendingSocket) -> Mono.just(acceptor.get().apply(sendingSocket)));
291280
}
292281

293282
public ClientTransportAcceptor acceptor(SocketAcceptor acceptor) {

0 commit comments

Comments
 (0)