@Test public void delete() throws Exception { int code = 200; statusCode.set(code); AtomicIntegerArray expected = copy(statusCounts); expected.addAndGet(code, 1); rxHttp.delete(uri("/empty").toString()).toBlocking().toFuture().get(); assertEquals(expected, statusCounts); }
public Observable<HttpClientResponse<ByteBuf>> delete(String uri) { return submit(HttpClientRequest.createDelete(uri)); }
RxHttp implements AutoCloseable { public Observable<HttpClientResponse<ByteBuf>> delete(String uri) { return submit(HttpClientRequest.createDelete(uri)); } }
RxHttp implements AutoCloseable { public Observable<HttpClientResponse<ByteBuf>> delete(String uri) { return submit(HttpClientRequest.createDelete(uri)); } @Inject  RxHttp(Config config, ServerRegistry serverRegistry); }
RxHttp implements AutoCloseable { public Observable<HttpClientResponse<ByteBuf>> delete(String uri) { return submit(HttpClientRequest.createDelete(uri)); } @Inject  RxHttp(Config config, ServerRegistry serverRegistry); @Deprecated void start(); @Deprecated void stop(); @Override void close(); Observable<HttpClientResponse<ByteBuf>> get(String uri); Observable<HttpClientResponse<ByteBuf>> get(URI uri); Observable<HttpClientResponse<ByteBuf>> getJson(String uri); Observable<HttpClientResponse<ByteBuf>> getJson(URI uri); Observable<HttpClientResponse<ByteBuf>> post(URI uri, String contentType, byte[] entity); Observable<HttpClientResponse<ByteBuf>> postJson(URI uri, byte[] entity); Observable<HttpClientResponse<ByteBuf>> postJson(URI uri, String entity); Observable<HttpClientResponse<ByteBuf>> postForm(URI uri); Observable<HttpClientResponse<ByteBuf>> put(URI uri, String contentType, byte[] entity); Observable<HttpClientResponse<ByteBuf>> putJson(URI uri, byte[] entity); Observable<HttpClientResponse<ByteBuf>> putJson(URI uri, String entity); Observable<HttpClientResponse<ByteBuf>> delete(String uri); Observable<HttpClientResponse<ByteBuf>> delete(URI uri); Observable<HttpClientResponse<ByteBuf>> deleteJson(String uri); Observable<HttpClientResponse<ByteBuf>> deleteJson(URI uri); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, String entity); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, byte[] entity); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, byte[] entity, SSLContext context); }
RxHttp implements AutoCloseable { public Observable<HttpClientResponse<ByteBuf>> delete(String uri) { return submit(HttpClientRequest.createDelete(uri)); } @Inject  RxHttp(Config config, ServerRegistry serverRegistry); @Deprecated void start(); @Deprecated void stop(); @Override void close(); Observable<HttpClientResponse<ByteBuf>> get(String uri); Observable<HttpClientResponse<ByteBuf>> get(URI uri); Observable<HttpClientResponse<ByteBuf>> getJson(String uri); Observable<HttpClientResponse<ByteBuf>> getJson(URI uri); Observable<HttpClientResponse<ByteBuf>> post(URI uri, String contentType, byte[] entity); Observable<HttpClientResponse<ByteBuf>> postJson(URI uri, byte[] entity); Observable<HttpClientResponse<ByteBuf>> postJson(URI uri, String entity); Observable<HttpClientResponse<ByteBuf>> postForm(URI uri); Observable<HttpClientResponse<ByteBuf>> put(URI uri, String contentType, byte[] entity); Observable<HttpClientResponse<ByteBuf>> putJson(URI uri, byte[] entity); Observable<HttpClientResponse<ByteBuf>> putJson(URI uri, String entity); Observable<HttpClientResponse<ByteBuf>> delete(String uri); Observable<HttpClientResponse<ByteBuf>> delete(URI uri); Observable<HttpClientResponse<ByteBuf>> deleteJson(String uri); Observable<HttpClientResponse<ByteBuf>> deleteJson(URI uri); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, String entity); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, byte[] entity); Observable<HttpClientResponse<ByteBuf>> submit(HttpClientRequest<ByteBuf> req, byte[] entity, SSLContext context);  }