@Test
public void testRequestUriFromPassedUri() throws Exception {

    final Func1<String, Observable<HttpClientRequest<ByteBuf>>> createPost = MesosClient.curryCreatePost(
        URI.create("http://localhost:12345/glavin/api/v1/scheduler"),
        StringMessageCodec.UTF8_STRING,
        StringMessageCodec.UTF8_STRING,
        new UserAgent(
            literal("testing", "latest")
        ),
        new AtomicReference<>(null)
    );
    final HttpClientRequest<ByteBuf> request = createPost.call("something")
        .toBlocking()
        .first();
    assertThat(request.getUri()).isEqualTo("/glavin/api/v1/scheduler");
}