Class SseMessageBodyReader
java.lang.Object
org.glassfish.jersey.microprofile.restclient.SseMessageBodyReader
- All Implemented Interfaces:
MessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
@Consumes("text/event-stream")
@ConstrainedTo(CLIENT)
public class SseMessageBodyReader
extends Object
implements MessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
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)
-
Field Details
-
providers
-
-
Constructor Details
-
SseMessageBodyReader
public SseMessageBodyReader()
-
-
Method Details
-
isReadable
public boolean isReadable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType) - Specified by:
isReadable
in interfaceMessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
-
readFrom
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- Specified by:
readFrom
in interfaceMessageBodyReader<org.reactivestreams.Publisher<InboundEvent>>
- Throws:
IOException
WebApplicationException
-