@Test public void testFetchEligibleCampaignsSuccess() { grpcServerRule .getServiceRegistry() .addService(new FakeFetchService(r -> assertEquals(fetchEligibleCampaignsRequest, r))); assertEquals( testFetchEligibleCampaignsResponse, grpcClient.fetchEligibleCampaigns(fetchEligibleCampaignsRequest)); }
public FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req) { return stub.withDeadlineAfter(30000, TimeUnit.MILLISECONDS).fetchEligibleCampaigns(req); }
GrpcClient { public FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req) { return stub.withDeadlineAfter(30000, TimeUnit.MILLISECONDS).fetchEligibleCampaigns(req); } }
GrpcClient { public FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req) { return stub.withDeadlineAfter(30000, TimeUnit.MILLISECONDS).fetchEligibleCampaigns(req); } @Inject  GrpcClient(InAppMessagingSdkServingBlockingStub stub); }
GrpcClient { public FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req) { return stub.withDeadlineAfter(30000, TimeUnit.MILLISECONDS).fetchEligibleCampaigns(req); } @Inject  GrpcClient(InAppMessagingSdkServingBlockingStub stub); FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req); }
GrpcClient { public FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req) { return stub.withDeadlineAfter(30000, TimeUnit.MILLISECONDS).fetchEligibleCampaigns(req); } @Inject  GrpcClient(InAppMessagingSdkServingBlockingStub stub); FetchEligibleCampaignsResponse fetchEligibleCampaigns(FetchEligibleCampaignsRequest req);  }