Skip to content

Commit f51ac1c

Browse files
authored
Merge pull request #61 from cbornet/lambdasubscriber
Remove LambdaSubscriber wrapping and use subscribe directly
2 parents e1b4abd + 8c0786b commit f51ac1c

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

rxgrpc/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import io.grpc.stub.StreamObserver;
1818
import io.reactivex.Flowable;
1919
import io.reactivex.Single;
20-
import io.reactivex.internal.subscribers.LambdaSubscriber;
2120
import io.reactivex.schedulers.Schedulers;
2221
import org.reactivestreams.Subscriber;
2322

@@ -132,7 +131,7 @@ public static <TRequest, TResponse> StreamObserver<TRequest> manyToMany(
132131
Subscriber<TResponse> subscriber = new RxFlowableBackpressureOnReadyHandler<>(
133132
(ServerCallStreamObserver<TResponse>) responseObserver);
134133
// Don't try to respond if the server has already canceled the request
135-
rxResponse.subscribe(new LambdaSubscriber<>(
134+
rxResponse.subscribe(
136135
tResponse -> {
137136
if (!streamObserverPublisher.isCanceled()) {
138137
subscriber.onNext(tResponse);
@@ -149,7 +148,7 @@ public static <TRequest, TResponse> StreamObserver<TRequest> manyToMany(
149148
}
150149
},
151150
subscriber::onSubscribe
152-
));
151+
);
153152
} catch (Throwable throwable) {
154153
responseObserver.onError(prepareError(throwable));
155154
}

0 commit comments

Comments
 (0)