io.servicetalk.http.router.jersey.resources

Class CancellableResources

java.lang.Object

io.servicetalk.http.router.jersey.resources.CancellableResources

@Path(value="/cancel")
public class CancellableResources
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PATH
java.util.concurrent.CountDownLatch	sseSinkClosedLatch

Constructor Summary

Constructors

Constructor and Description
CancellableResources()

Method Summary

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

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

sseSinkClosedLatch

public final java.util.concurrent.CountDownLatch sseSinkClosedLatch

Constructor Detail

CancellableResources

public CancellableResources()

Method Detail

getForeverSuspended

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

getSingleNever

@Produces(value="text/plain")
 @Path(value="/single")
 @GET
public Single<java.lang.String> getSingleNever()

getOffloadedBlocked

@RouteExecutionStrategy(id="test")
 @Produces(value="text/plain")
 @Path(value="/offload")
 @GET
public java.lang.String getOffloadedBlocked()
                                                                                                                                      throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

postOioStreams

@Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/oio-streams")
 @POST
public javax.ws.rs.core.StreamingOutput postOioStreams(java.io.InputStream requestContent)

postOffloadedOioStreams

@RouteExecutionStrategy(id="test")
 @Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/offload-oio-streams")
 @POST
public javax.ws.rs.core.StreamingOutput postOffloadedOioStreams(java.io.InputStream requestContent)

postNoOffloadsOioStreams

@NoOffloadsRouteExecutionStrategy
 @Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/no-offloads-oio-streams")
 @POST
public javax.ws.rs.core.StreamingOutput postNoOffloadsOioStreams(java.io.InputStream requestContent)

postRsStreams

@Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/rs-streams")
 @POST
public Publisher<Buffer> postRsStreams(@QueryParam(value="subscribe")
                                                                                                                                       boolean subscribe,
                                                                                                                                       Publisher<Buffer> requestContent,
                                                                                                                                       @Context
                                                                                                                                       ConnectionContext ctx)

postOffloadedRsStreams

@RouteExecutionStrategy(id="test")
 @Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/offload-rs-streams")
 @POST
public Publisher<Buffer> postOffloadedRsStreams(@QueryParam(value="subscribe")
                                                                                                                                                                                            boolean subscribe,
                                                                                                                                                                                            Publisher<Buffer> requestContent,
                                                                                                                                                                                            @Context
                                                                                                                                                                                            ConnectionContext ctx)

postNoOffloadsRsStreams

@NoOffloadsRouteExecutionStrategy
 @Consumes(value="text/plain")
 @Produces(value="text/plain")
 @Path(value="/no-offloads-rs-streams")
 @POST
public Publisher<Buffer> postNoOffloadsRsStreams(@QueryParam(value="subscribe")
                                                                                                                                                                                                boolean subscribe,
                                                                                                                                                                                                Publisher<Buffer> requestContent,
                                                                                                                                                                                                @Context
                                                                                                                                                                                                ConnectionContext ctx)

getSseStream

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