Merge pull request #61 from cbornet/lambdasubscriber

Remove LambdaSubscriber wrapping and use subscribe directly

Author: rmichela

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 <TRequest, TResponse> StreamObserver<TRequest> manyToMany(
             Subscriber<TResponse> subscriber = new RxFlowableBackpressureOnReadyHandler<>(
                     (ServerCallStreamObserver<TResponse>) 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 <TRequest, TResponse> StreamObserver<TRequest> manyToMany(
                     }
                 },
                 subscriber::onSubscribe
-            ));
+            );
         } catch (Throwable throwable) {
             responseObserver.onError(prepareError(throwable));
         }