@Test(groups = "unit", dataProvider = "fromMockedNetworkFailureToExpectedDocumentClientException")
public void networkFailures(RxDocumentServiceRequest request,
                            HttpClientMockWrapper.HttpClientBehaviourBuilder mockedResponseBuilder,
                            FailureValidator.Builder failureValidatorBuilder) {

    HttpClientMockWrapper httpClientMockWrapper = new HttpClientMockWrapper(mockedResponseBuilder);
    UserAgentContainer userAgentContainer = new UserAgentContainer();
    HttpTransportClient transportClient = getHttpTransportClientUnderTest(
            100,
            userAgentContainer,
            httpClientMockWrapper.getClient());
    Single<StoreResponse> storeResp = transportClient.invokeStoreAsync(
            Uri.create(physicalAddress),
            new ResourceOperation(OperationType.Create, ResourceType.Document),
            request);
    validateFailure(storeResp, failureValidatorBuilder.build());
}