Class AsynchronousResources
- java.lang.Object
-
- io.servicetalk.http.router.jersey.resources.AsynchronousResources
-
@Path("/async") public class AsynchronousResources extends java.lang.Object
Asynchronous (in JAX-RS lingo) resources.
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
PATH
-
Constructor Summary
Constructors Constructor Description AsynchronousResources()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
explicitHead(java.lang.String requestContent)
void
getAsyncResponseBusy(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseCancel(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseResume(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseResumeTimeout(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseTimeoutExpire(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseTimeoutExpireHandled(javax.ws.rs.container.AsyncResponse ar)
void
getAsyncResponseTimeoutResume(javax.ws.rs.container.AsyncResponse ar)
Completable
getCompletableOut(boolean fail)
javax.ws.rs.core.Response
getDelayedResponseCompletionStage(long delay, java.util.concurrent.TimeUnit unit)
java.util.concurrent.CompletionStage<java.lang.String>
getDelayedText(long delay, java.util.concurrent.TimeUnit unit)
java.util.concurrent.CompletionStage<java.lang.String>
getFailed(boolean cancel)
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.lang.Object>>
getJson()
void
getJsonAsyncResponse(javax.ws.rs.container.AsyncResponse ar)
Single<java.util.Map<java.lang.String,java.lang.Object>>
getMapSingle(boolean fail)
Single<TestPojo>
getPojoSingle(boolean fail)
javax.ws.rs.core.Response
getResponseCompletionStage(javax.ws.rs.core.HttpHeaders headers)
Single<javax.ws.rs.core.Response>
getResponseSingle(boolean fail)
Single<javax.ws.rs.core.Response>
getResponseSinglePublisherEntity(int i)
void
getSseBroadcast(javax.ws.rs.sse.SseEventSink eventSink, javax.ws.rs.sse.Sse sse)
void
getSseStream(javax.ws.rs.sse.SseEventSink eventSink, javax.ws.rs.sse.Sse sse)
void
getSseUnsupportedType(javax.ws.rs.sse.SseEventSink eventSink, javax.ws.rs.sse.Sse sse)
Single<java.lang.String>
getStringSingle(boolean fail)
java.util.concurrent.CompletionStage<java.lang.String>
getText(java.lang.String qp, boolean nullResult, java.lang.String hp)
java.util.concurrent.CompletionStage<Buffer>
getTextBuffer()
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
getTextBufferResponse(javax.ws.rs.core.HttpHeaders headers)
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
getTextPubResponse(int i)
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
getTextResponse(javax.ws.rs.core.HttpHeaders headers)
java.util.concurrent.CompletionStage<java.lang.Void>
getVoidCompletion(boolean fail, boolean defer)
java.util.concurrent.CompletionStage<java.lang.String>
postFiltered(java.lang.String requestContent)
java.util.concurrent.CompletionStage<java.util.Map<java.lang.String,java.lang.Object>>
postJson(java.util.Map<java.lang.String,java.lang.Object> requestContent)
java.util.concurrent.CompletionStage<Buffer>
postJsonBuffer(Buffer requestContent)
Single<Buffer>
postJsonBufSingleInSingleOut(boolean fail, Single<Buffer> requestContent)
java.util.concurrent.CompletionStage<byte[]>
postJsonBytes(byte[] requestContent)
java.util.concurrent.CompletionStage<TestPojo>
postJsonPojo(TestPojo testPojo)
Single<javax.ws.rs.core.Response>
postJsonPojoInPojoOutResponseSingle(boolean fail, TestPojo testPojo)
Single<TestPojo>
postJsonPojoInPojoOutSingle(boolean fail, TestPojo testPojo)
java.util.concurrent.CompletionStage<java.lang.String>
postText(java.lang.String requestContent)
java.util.concurrent.CompletionStage<Buffer>
postTextBuffer(Buffer requestContent)
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
postTextBufferResponse(Buffer requestContent)
java.util.concurrent.CompletionStage<byte[]>
postTextBytes(byte[] requestContent)
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
postTextResponse(java.lang.String requestContent)
java.util.concurrent.CompletionStage<javax.ws.rs.core.Response>
putJsonResponse(java.util.Map<java.lang.String,java.lang.Object> requestContent)
-
-
-
Field Detail
-
PATH
public static final java.lang.String PATH
- See Also:
- Constant Field Values
-
-
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)
-
-