@Consumes(value="text/event-stream") @ConstrainedTo(value=CLIENT) public class SseMessageBodyReader extends Object implements MessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
Constructor and Description |
---|
SseMessageBodyReader() |
Modifier and Type | Method and Description |
---|---|
boolean |
isReadable(Class<?> type,
Type genericType,
Annotation[] annotations,
MediaType mediaType) |
org.reactivestreams.Publisher<InboundEvent> |
readFrom(Class<org.reactivestreams.Publisher<InboundEvent>> chunkedInputClass,
Type genericType,
Annotation[] annotations,
MediaType mediaType,
MultivaluedMap<String,String> headers,
InputStream inputStream) |
public boolean isReadable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType)
isReadable
in interface MessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
public org.reactivestreams.Publisher<InboundEvent> readFrom(Class<org.reactivestreams.Publisher<InboundEvent>> chunkedInputClass, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap<String,String> headers, InputStream inputStream) throws IOException, WebApplicationException
readFrom
in interface MessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
IOException
WebApplicationException
Copyright © 2007-2023, Oracle and/or its affiliates. All Rights Reserved. Use is subject to license terms.