Examples of com.google.mockwebserver.MockWebServer.shutdown()

Class com.google.mockwebserver.MockWebServer

Examples of com.google.mockwebserver.MockWebServer.shutdown()

com.google.mockwebserver.MockWebServer.shutdown()


      Response response = api.response();
      assertTrue(response.body().isRepeatable());
      assertEquals(response.body().toString(), "foo");
    } finally {
      server.shutdown();
    }
  }


  @Test
  public void postFormParams() throws IOException, InterruptedException {

View Full Code Here


      api.form("netflix", "denominator", "password");
      assertEquals(new String(server.takeRequest().getBody(), UTF_8),
          "customer_name=netflix,user_name=denominator,password=password");
    } finally {
      server.shutdown();
    }
  }


  @Test
  public void postBodyParam() throws IOException, InterruptedException {

View Full Code Here

      api.body(Arrays.asList("netflix", "denominator", "password"));
      RecordedRequest request = server.takeRequest();
      assertEquals(request.getHeader("Content-Length"), "32");
      assertEquals(new String(request.getBody(), UTF_8), "[netflix, denominator, password]");
    } finally {
      server.shutdown();
    }
  }


  @Test
  public void postGZIPEncodedBodyParam() throws IOException, InterruptedException {

View Full Code Here

      byte[] compressedBody = request.getBody();
      String uncompressedBody = CharStreams.toString(CharStreams.newReaderSupplier(
          GZIPStreams.newInputStreamSupplier(ByteStreams.newInputStreamSupplier(compressedBody)), UTF_8));
      assertEquals(uncompressedBody, "[netflix, denominator, password]");
    } finally {
      server.shutdown();
    }
  }


  @Module(library = true)
  static class ForwardedForInterceptor implements RequestInterceptor {

View Full Code Here

          new TestInterface.Module(), new ForwardedForInterceptor());


      api.post();
      assertEquals(server.takeRequest().getHeader("X-Forwarded-For"), "origin.host.com");
    } finally {
      server.shutdown();
    }
  }


  @Module(library = true)
  static class UserAgentInterceptor implements RequestInterceptor {

View Full Code Here

      api.post();
      RecordedRequest request = server.takeRequest();
      assertEquals(request.getHeader("X-Forwarded-For"), "origin.host.com");
      assertEquals(request.getHeader("User-Agent"), "Feign");
    } finally {
      server.shutdown();
    }
  }


  @Test public void toKeyMethodFormatsAsExpected() throws Exception {
    assertEquals(Feign.configKey(TestInterface.class.getDeclaredMethod("post")), "TestInterface#post()");

View Full Code Here

      TestInterface api = Feign.create(TestInterface.class, "http://localhost:" + server.getPort(),
          new IllegalArgumentExceptionOn404());


      api.post();
    } finally {
      server.shutdown();
    }
  }


  @Test public void retriesLostConnectionBeforeRead() throws IOException, InterruptedException {
    MockWebServer server = new MockWebServer();

View Full Code Here


      api.post();
      assertEquals(server.getRequestCount(), 2);


    } finally {
      server.shutdown();
    }
  }


  @dagger.Module(overrides = true, library = true, includes = TestInterface.Module.class)
  static class DecodeFail {

View Full Code Here

      TestInterface api = Feign.create(TestInterface.class, "http://localhost:" + server.getPort(),
          new DecodeFail());


      assertEquals(api.post(), "fail");
    } finally {
      server.shutdown();
      assertEquals(server.getRequestCount(), 1);
    }
  }


  @dagger.Module(overrides = true, library = true, includes = TestInterface.Module.class)

View Full Code Here

      TestInterface api = Feign.create(TestInterface.class, "http://localhost:" + server.getPort(),
          new RetryableExceptionOnRetry());


      assertEquals(api.post(), "success!");
    } finally {
      server.shutdown();
      assertEquals(server.getRequestCount(), 2);
    }
  }


  @dagger.Module(overrides = true, library = true, includes = TestInterface.Module.class)

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.