@Test
public void testServerStreaming() throws Exception {

  CountDownLatch latch = new CountDownLatch(2);
  MoneyObserver moneyObserver = new MoneyObserver(true, latch);
  streamingCallable.call(DEFAULT_REQUEST, moneyObserver);
  latch.await(20, TimeUnit.SECONDS);
  Truth.assertThat(moneyObserver.error).isNull();
  Truth.assertThat(moneyObserver.response).isEqualTo(DEFAULT_RESPONSE);
}