@Test
@SuppressWarnings("all")
public void searchStreamTest() throws Exception {

  SearchGoogleAdsStreamResponse expectedResponse =
      SearchGoogleAdsStreamResponse.newBuilder().build();
  mockGoogleAdsService.addResponse(expectedResponse);
  String customerId = "customerId-1772061412";
  String query = "query107944136";
  SearchGoogleAdsStreamRequest request =
      SearchGoogleAdsStreamRequest.newBuilder().setCustomerId(customerId).setQuery(query).build();
  MockStreamObserver<SearchGoogleAdsStreamResponse> responseObserver = new MockStreamObserver<>();
  ServerStreamingCallable<SearchGoogleAdsStreamRequest, SearchGoogleAdsStreamResponse> callable =
      client.searchStreamCallable();
  callable.serverStreamingCall(request, responseObserver);
  List<SearchGoogleAdsStreamResponse> actualResponses = responseObserver.future().get();
  Assert.assertEquals(1, actualResponses.size());
  Assert.assertEquals(expectedResponse, actualResponses.get(0));
}