Package io.servicetalk.http.router.jersey.resources

Class AsynchronousResources

  • @Path("/async")
public class AsynchronousResources
extends java.lang.Object
    Asynchronous (in JAX-RS lingo) resources.

    • Constructor Detail

      • AsynchronousResources

        public AsynchronousResources()

    • Method Detail

      • getCompletableOut

        @Path("/completable")
@GET
public Completable getCompletableOut​(@QueryParam("fail")
                                     boolean fail)

      • getStringSingle

        @Produces("text/plain")
@Path("/single-string")
@GET
public Single<java.lang.String> getStringSingle​(@QueryParam("fail")
                                                boolean fail)

      • postJsonBufSingleInSingleOut

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-buf-sglin-sglout")
@POST
public Single<Buffer> postJsonBufSingleInSingleOut​(@QueryParam("fail")
                                                   boolean fail,
                                                   Single<Buffer> requestContent)

      • getResponseSingle

        @Produces("text/plain")
@Path("/single-response")
@GET
public Single<javax.ws.rs.core.Response> getResponseSingle​(@QueryParam("fail")
                                                           boolean fail)

      • getResponseSinglePublisherEntity

        @Produces("text/plain")
@Path("/single-response-pub-entity")
@GET
public Single<javax.ws.rs.core.Response> getResponseSinglePublisherEntity​(@QueryParam("i")
                                                                          int i)

      • getMapSingle

        @Produces("application/json")
@Path("/single-map")
@GET
public Single<java.util.Map<java.lang.String,​java.lang.Object>> getMapSingle​(@QueryParam("fail")
                                                                                   boolean fail)

      • getPojoSingle

        @Produces("application/json")
@Path("/single-pojo")
@GET
public Single<TestPojo> getPojoSingle​(@QueryParam("fail")
                                      boolean fail)

      • postJsonPojoInPojoOutSingle

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-pojoin-pojoout-single")
@POST
public Single<TestPojo> postJsonPojoInPojoOutSingle​(@QueryParam("fail")
                                                    boolean fail,
                                                    TestPojo testPojo)

      • postJsonPojoInPojoOutResponseSingle

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-pojoin-pojoout-response-single")
@POST
public Single<javax.ws.rs.core.Response> postJsonPojoInPojoOutResponseSingle​(@QueryParam("fail")
                                                                             boolean fail,
                                                                             TestPojo testPojo)

      • getVoidCompletion

        @Path("/void-completion")
@GET
public java.util.concurrent.CompletionStage<java.lang.Void> getVoidCompletion​(@QueryParam("fail")
                                                                              boolean fail,
                                                                              @QueryParam("defer")
                                                                              boolean defer)

      • explicitHead

        @Produces("text/plain")
@Path("/head")
@HEAD
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> explicitHead​(java.lang.String requestContent)

      • getText

        @Produces("text/plain")
@Path("/text")
@GET
public java.util.concurrent.CompletionStage<java.lang.String> getText​(@Nullable @QueryParam("qp")
                                                                      java.lang.String qp,
                                                                      @QueryParam("null")
                                                                      boolean nullResult,
                                                                      @Nullable @HeaderParam("hp")
                                                                      java.lang.String hp)

      • getFailed

        @Produces("text/plain")
@Path("/failed-text")
@GET
public java.util.concurrent.CompletionStage<java.lang.String> getFailed​(@QueryParam("cancel")
                                                                        boolean cancel)

      • getDelayedText

        @Produces("text/plain")
@Path("/delayed-text")
@GET
public java.util.concurrent.CompletionStage<java.lang.String> getDelayedText​(@Nonnull @QueryParam("delay")
                                                                             long delay,
                                                                             @Nonnull @QueryParam("unit")
                                                                             java.util.concurrent.TimeUnit unit)

      • postText

        @Consumes("text/plain")
@Produces("text/plain")
@Path("/text")
@POST
public java.util.concurrent.CompletionStage<java.lang.String> postText​(java.lang.String requestContent)

      • getTextResponse

        @Produces("text/plain")
@Path("/text-response")
@GET
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> getTextResponse​(@Context
                                                                                       javax.ws.rs.core.HttpHeaders headers)

      • postTextResponse

        @Produces("text/plain")
@Path("/text-response")
@POST
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> postTextResponse​(java.lang.String requestContent)

      • getTextBuffer

        @Produces("text/plain")
@Path("/text-buffer")
@GET
public java.util.concurrent.CompletionStage<Buffer> getTextBuffer()

      • postTextBuffer

        @Consumes("text/plain")
@Produces("text/plain")
@Path("/text-buffer")
@POST
public java.util.concurrent.CompletionStage<Buffer> postTextBuffer​(Buffer requestContent)

      • postJsonBuffer

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-buffer")
@POST
public java.util.concurrent.CompletionStage<Buffer> postJsonBuffer​(Buffer requestContent)

      • postTextBytes

        @Consumes("text/plain")
@Produces("text/plain")
@Path("/text-bytes")
@POST
public java.util.concurrent.CompletionStage<byte[]> postTextBytes​(byte[] requestContent)

      • postJsonBytes

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-bytes")
@POST
public java.util.concurrent.CompletionStage<byte[]> postJsonBytes​(byte[] requestContent)

      • getTextBufferResponse

        @Produces("text/plain")
@Path("/text-buffer-response")
@GET
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> getTextBufferResponse​(@Context
                                                                                             javax.ws.rs.core.HttpHeaders headers)

      • postTextBufferResponse

        @Produces("text/plain")
@Path("/text-buffer-response")
@POST
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> postTextBufferResponse​(Buffer requestContent)

      • getTextPubResponse

        @Produces("text/plain")
@Path("/text-pub-response")
@GET
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> getTextPubResponse​(@QueryParam("i")
                                                                                          int i)

      • getResponseCompletionStage

        @Produces("text/plain")
@Path("/response-comsta")
@GET
public javax.ws.rs.core.Response getResponseCompletionStage​(@Context
                                                            javax.ws.rs.core.HttpHeaders headers)

      • getDelayedResponseCompletionStage

        @Produces("text/plain")
@Path("/delayed-response-comsta")
@GET
public javax.ws.rs.core.Response getDelayedResponseCompletionStage​(@Nonnull @QueryParam("delay")
                                                                   long delay,
                                                                   @Nonnull @QueryParam("unit")
                                                                   java.util.concurrent.TimeUnit unit)

      • postFiltered

        @Produces("text/plain")
@Path("/filtered")
@POST
public java.util.concurrent.CompletionStage<java.lang.String> postFiltered​(java.lang.String requestContent)

      • getJson

        @Produces("application/json")
@Path("/json")
@GET
public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,​java.lang.Object>> getJson()

      • postJson

        @Consumes("application/json")
@Produces("application/json")
@Path("/json")
@POST
public java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,​java.lang.Object>> postJson​(java.util.Map<java.lang.String,​java.lang.Object> requestContent)

      • putJsonResponse

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-response")
@PUT
public java.util.concurrent.CompletionStage<javax.ws.rs.core.Response> putJsonResponse​(java.util.Map<java.lang.String,​java.lang.Object> requestContent)

      • postJsonPojo

        @Consumes("application/json")
@Produces("application/json")
@Path("/json-pojoin-pojoout")
@POST
public java.util.concurrent.CompletionStage<TestPojo> postJsonPojo​(TestPojo testPojo)

      • getAsyncResponseResume

        @Produces("text/plain")
@Path("/suspended/resume")
@GET
public void getAsyncResponseResume​(@Suspended
                                   javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseCancel

        @Produces("text/plain")
@Path("/suspended/cancel")
@GET
public void getAsyncResponseCancel​(@Suspended
                                   javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseTimeoutResume

        @Produces("text/plain")
@Path("/suspended/timeout-resume")
@GET
public void getAsyncResponseTimeoutResume​(@Suspended
                                          javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseTimeoutExpire

        @Produces("text/plain")
@Path("/suspended/timeout-expire")
@GET
public void getAsyncResponseTimeoutExpire​(@Suspended
                                          javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseTimeoutExpireHandled

        @Produces("text/plain")
@Path("/suspended/timeout-expire-handled")
@GET
public void getAsyncResponseTimeoutExpireHandled​(@Suspended
                                                 javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseResumeTimeout

        @Produces("text/plain")
@Path("/suspended/resume-timeout")
@GET
public void getAsyncResponseResumeTimeout​(@Suspended
                                          javax.ws.rs.container.AsyncResponse ar)

      • getAsyncResponseBusy

        @Produces("text/plain")
@Path("/suspended/busy")
@GET
public void getAsyncResponseBusy​(@Suspended
                                 javax.ws.rs.container.AsyncResponse ar)

      • getJsonAsyncResponse

        @Produces("application/json")
@Path("/suspended/json")
@GET
public void getJsonAsyncResponse​(@Suspended
                                 javax.ws.rs.container.AsyncResponse ar)

      • getSseStream

        @Produces("text/event-stream")
@Path("/sse/stream")
@GET
public void getSseStream​(@Context
                         javax.ws.rs.sse.SseEventSink eventSink,
                         @Context
                         javax.ws.rs.sse.Sse sse)

      • getSseBroadcast

        @Produces("text/event-stream")
@Path("/sse/broadcast")
@GET
public void getSseBroadcast​(@Context
                            javax.ws.rs.sse.SseEventSink eventSink,
                            @Context
                            javax.ws.rs.sse.Sse sse)

      • getSseUnsupportedType

        @Produces("text/event-stream")
@Path("/sse/unsupported")
@GET
public void getSseUnsupportedType​(@Context
                                  javax.ws.rs.sse.SseEventSink eventSink,
                                  @Context
                                  javax.ws.rs.sse.Sse sse)