From 8c0786be3527d3594804dc64ed9e46d63b855806 Mon Sep 17 00:00:00 2001 From: cbornet Date: Mon, 6 Nov 2017 08:11:54 +0000 Subject: [PATCH] Remove LambdaSubscriber wrapping and use subscribe directly --- .../main/java/com/salesforce/rxgrpc/stub/ServerCalls.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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)); }