io.servicetalk.http.router.jersey.resources

Class AsynchronousResources

java.lang.Object

io.servicetalk.http.router.jersey.resources.AsynchronousResources

@Path(value="/async")
public class AsynchronousResources
extends java.lang.Object

Asynchronous (in JAX-RS lingo) resources.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PATH

Constructor Summary

Constructors

Constructor and Description
AsynchronousResources()

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PATH

public static final java.lang.String PATH

See Also:

Constant Field Values

Constructor Detail

AsynchronousResources

public AsynchronousResources()

Method Detail

getCompletableOut

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

getStringSingle

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

postJsonBufSingleInSingleOut

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

getResponseSingle

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

getResponseSinglePublisherEntity

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

getMapSingle

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

getPojoSingle

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

postJsonPojoInPojoOutSingle

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

postJsonPojoInPojoOutResponseSingle

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

getVoidCompletion

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

explicitHead

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

getText

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

getFailed

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

getDelayedText

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

postText

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

getTextResponse

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

postTextResponse

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

getTextBuffer

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

postTextBuffer

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

postJsonBuffer

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

postTextBytes

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

postJsonBytes

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

getTextBufferResponse

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

postTextBufferResponse

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

getTextPubResponse

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

getResponseCompletionStage

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

getDelayedResponseCompletionStage

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

postFiltered

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

getJson

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

postJson

@Consumes(value="application/json")
 @Produces(value="application/json")
 @Path(value="/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(value="application/json")
 @Produces(value="application/json")
 @Path(value="/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(value="application/json")
 @Produces(value="application/json")
 @Path(value="/json-pojoin-pojoout")
 @POST
public java.util.concurrent.CompletionStage<TestPojo> postJsonPojo(TestPojo testPojo)

getAsyncResponseResume

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

getAsyncResponseCancel

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

getAsyncResponseTimeoutResume

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

getAsyncResponseTimeoutExpire

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

getAsyncResponseTimeoutExpireHandled

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

getAsyncResponseResumeTimeout

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

getAsyncResponseBusy

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

getJsonAsyncResponse

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

getSseStream

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

getSseBroadcast

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

getSseUnsupportedType

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