ServerStreamingCallable { @Deprecated public void serverStreamingCall( RequestT request, final ApiStreamObserver<ResponseT> responseObserver, ApiCallContext context) { call(request, new ApiStreamObserverAdapter<>(responseObserver), context); } protected  ServerStreamingCallable(); UnaryCallable<RequestT, ResponseT> first(); UnaryCallable<RequestT, List<ResponseT>> all(); ServerStream<ResponseT> call(RequestT request); ServerStream<ResponseT> call(RequestT request, ApiCallContext context); abstract void call(
      RequestT request, ResponseObserver<ResponseT> responseObserver, ApiCallContext context); void call(RequestT request, ResponseObserver<ResponseT> responseObserver); @Deprecated void serverStreamingCall(
      RequestT request,
      final ApiStreamObserver<ResponseT> responseObserver,
      ApiCallContext context); @Deprecated void serverStreamingCall(RequestT request, ApiStreamObserver<ResponseT> responseObserver); @Deprecated Iterator<ResponseT> blockingServerStreamingCall(RequestT request, ApiCallContext context); @Deprecated Iterator<ResponseT> blockingServerStreamingCall(RequestT request); ServerStreamingCallable<RequestT, ResponseT> withDefaultCallContext(
      final ApiCallContext defaultCallContext);  }
@Test public void testServerStreamingCall() { ApiCallContext defaultCallContext = FakeCallContext.createDefault(); ServerStreamingStashCallable<Integer, Integer> stashCallable = new ServerStreamingStashCallable<>(); ServerStreamingCallable<Integer, Integer> callable = stashCallable.withDefaultCallContext(defaultCallContext); @SuppressWarnings("unchecked") StateCheckingResponseObserver<Integer> observer = Mockito.mock(StateCheckingResponseObserver.class); Integer request = 1; callable.call(request, observer); Truth.assertThat(stashCallable.getActualObserver()).isSameInstanceAs(observer); Truth.assertThat(stashCallable.getActualRequest()).isSameInstanceAs(request); Truth.assertThat(stashCallable.getContext()).isSameInstanceAs(defaultCallContext); }