@Test
public void bidiStreaming_BidiStreamObserver() throws InterruptedException {

  BidiStreamingStashCallable<Integer, Integer> callIntList =
      new BidiStreamingStashCallable<>(Arrays.asList(0, 1, 2));
  BidiStreamingCallable<Integer, Integer> callable =
      FakeCallableFactory.createBidiStreamingCallable(
          callIntList,
          StreamingCallSettings.<Integer, Integer>newBuilder().build(),
          clientContext);
  AccumulatingBidiObserver observer = new AccumulatingBidiObserver(Arrays.asList(3, 4, 5));
  callable.call(observer);
  assertThat(observer.getResponses()).containsExactly(0, 1, 2).inOrder();
  assertThat(callIntList.getActualRequests()).containsExactly(3, 4, 5).inOrder();
}