diff --git a/rxgrpc/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java b/rxgrpc/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java index 580284a1..fddbeeca 100644 --- a/rxgrpc/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java +++ b/rxgrpc/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java @@ -17,7 +17,6 @@ import io.grpc.stub.StreamObserver; import io.reactivex.Flowable; import io.reactivex.Single; -import io.reactivex.internal.subscribers.LambdaSubscriber; import io.reactivex.schedulers.Schedulers; import org.reactivestreams.Subscriber; @@ -132,7 +131,7 @@ public static StreamObserver manyToMany( Subscriber subscriber = new RxFlowableBackpressureOnReadyHandler<>( (ServerCallStreamObserver) responseObserver); // Don't try to respond if the server has already canceled the request - rxResponse.subscribe(new LambdaSubscriber<>( + rxResponse.subscribe( tResponse -> { if (!streamObserverPublisher.isCanceled()) { subscriber.onNext(tResponse); @@ -149,7 +148,7 @@ public static StreamObserver manyToMany( } }, subscriber::onSubscribe - )); + ); } catch (Throwable throwable) { responseObserver.onError(prepareError(throwable)); }