@Test
public void testNoErrorsAutoFlow() {

  ServerStreamingAttemptCallable<String, String> callable = createCallable();
  callable.start();
  // Should notify outer observer
  Truth.assertThat(observer.controller).isNotNull();
  // Should configure the inner controller correctly.
  MockServerStreamingCall<String, String> call = innerCallable.popLastCall();
  Truth.assertThat(call.getController().isAutoFlowControlEnabled()).isTrue();
  Truth.assertThat(call.getRequest()).isEqualTo("request");
  // Send a response in auto flow mode.
  call.getController().getObserver().onResponse("response1");
  call.getController().getObserver().onResponse("response2");
  call.getController().getObserver().onComplete();
  // Make sure the responses are received
  Truth.assertThat(observer.responses).containsExactly("response1", "response2").inOrder();
  fakeRetryingFuture.assertSuccess();
}