  @Test
  public void testRouterClosedDuringOperation() throws Exception {

    setServerResponse(false);
    testWithErrorCodes(Collections.singletonMap(ServerErrorCode.No_Error, 9), serverLayout,
        RouterErrorCode.RouterClosed, new ErrorCodeChecker() {
          @Override
          public void testAndAssert(RouterErrorCode expectedError) throws Exception {
            future = router.deleteBlob(blobIdString, null);
            router.close();
            assertFailureAndCheckErrorCode(future, expectedError);
          }
        });
  }