HttpIT.java 文件源码

@Test
public void testForEach()
        throws Exception
{
    String uri = "http://localhost:" + httpMockWebServer.getPort() + "/";
    httpMockWebServer.setDispatcher(new QueueDispatcher());
    String content = DigdagClient.objectMapper().writeValueAsString(
            ImmutableList.of("foo", "bar", "baz"));
    httpMockWebServer.enqueue(new MockResponse().setBody(content));
    runWorkflow(folder, "acceptance/http/http_for_each.dig", ImmutableMap.of("test_uri", uri));
    assertThat(httpMockWebServer.getRequestCount(), is(1));
}