Class CancellableResources
- java.lang.Object
-
- io.servicetalk.http.router.jersey.resources.CancellableResources
-
@Path("/cancel") public class CancellableResources extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
PATH
java.util.concurrent.CountDownLatch
sseSinkClosedLatch
-
Constructor Summary
Constructors Constructor Description CancellableResources()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
getForeverSuspended(javax.ws.rs.container.AsyncResponse ar)
java.lang.String
getOffloadedBlocked()
Single<java.lang.String>
getSingleNever()
void
getSseStream(javax.ws.rs.sse.SseEventSink eventSink, javax.ws.rs.sse.Sse sse, ConnectionContext ctx)
javax.ws.rs.core.StreamingOutput
postNoOffloadsOioStreams(java.io.InputStream requestContent)
Publisher<Buffer>
postNoOffloadsRsStreams(boolean subscribe, Publisher<Buffer> requestContent, ConnectionContext ctx)
javax.ws.rs.core.StreamingOutput
postOffloadedOioStreams(java.io.InputStream requestContent)
Publisher<Buffer>
postOffloadedRsStreams(boolean subscribe, Publisher<Buffer> requestContent, ConnectionContext ctx)
javax.ws.rs.core.StreamingOutput
postOioStreams(java.io.InputStream requestContent)
Publisher<Buffer>
postRsStreams(boolean subscribe, Publisher<Buffer> requestContent, ConnectionContext ctx)
-
-
-
Field Detail
-
PATH
public static final java.lang.String PATH
- See Also:
- Constant Field Values
-
sseSinkClosedLatch
public final java.util.concurrent.CountDownLatch sseSinkClosedLatch
-
-
Method Detail
-
getForeverSuspended
@Path("/suspended") @GET public void getForeverSuspended(@Suspended javax.ws.rs.container.AsyncResponse ar)
-
getSingleNever
@Produces("text/plain") @Path("/single") @GET public Single<java.lang.String> getSingleNever()
-
getOffloadedBlocked
@RouteExecutionStrategy(id="test") @Produces("text/plain") @Path("/offload") @GET public java.lang.String getOffloadedBlocked() throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
postOioStreams
@Consumes("text/plain") @Produces("text/plain") @Path("/oio-streams") @POST public javax.ws.rs.core.StreamingOutput postOioStreams(java.io.InputStream requestContent)
-
postOffloadedOioStreams
@RouteExecutionStrategy(id="test") @Consumes("text/plain") @Produces("text/plain") @Path("/offload-oio-streams") @POST public javax.ws.rs.core.StreamingOutput postOffloadedOioStreams(java.io.InputStream requestContent)
-
postNoOffloadsOioStreams
@NoOffloadsRouteExecutionStrategy @Consumes("text/plain") @Produces("text/plain") @Path("/no-offloads-oio-streams") @POST public javax.ws.rs.core.StreamingOutput postNoOffloadsOioStreams(java.io.InputStream requestContent)
-
postRsStreams
@Consumes("text/plain") @Produces("text/plain") @Path("/rs-streams") @POST public Publisher<Buffer> postRsStreams(@QueryParam("subscribe") boolean subscribe, Publisher<Buffer> requestContent, @Context ConnectionContext ctx)
-
postOffloadedRsStreams
@RouteExecutionStrategy(id="test") @Consumes("text/plain") @Produces("text/plain") @Path("/offload-rs-streams") @POST public Publisher<Buffer> postOffloadedRsStreams(@QueryParam("subscribe") boolean subscribe, Publisher<Buffer> requestContent, @Context ConnectionContext ctx)
-
postNoOffloadsRsStreams
@NoOffloadsRouteExecutionStrategy @Consumes("text/plain") @Produces("text/plain") @Path("/no-offloads-rs-streams") @POST public Publisher<Buffer> postNoOffloadsRsStreams(@QueryParam("subscribe") boolean subscribe, Publisher<Buffer> requestContent, @Context ConnectionContext ctx)
-
getSseStream
@Produces("text/event-stream") @Path("/sse") @GET public void getSseStream(@Context javax.ws.rs.sse.SseEventSink eventSink, @Context javax.ws.rs.sse.Sse sse, @Context ConnectionContext ctx)
-
-