Class MpPublisherMessageBodyReader

  • All Implemented Interfaces:
    javax.ws.rs.ext.MessageBodyReader<org.reactivestreams.Publisher<?>>

    @Provider
    @Consumes("text/event-stream")
    public class MpPublisherMessageBodyReader
    extends Object
    implements javax.ws.rs.ext.MessageBodyReader<org.reactivestreams.Publisher<?>>
    • Field Detail

      • providers

        @Context
        protected javax.ws.rs.ext.Providers providers
    • Constructor Detail

      • MpPublisherMessageBodyReader

        public MpPublisherMessageBodyReader​(ExecutorService ex)
      • MpPublisherMessageBodyReader

        public MpPublisherMessageBodyReader()
    • Method Detail

      • isReadable

        public boolean isReadable​(Class<?> type,
                                  Type genericType,
                                  Annotation[] annotations,
                                  javax.ws.rs.core.MediaType mediaType)
        Specified by:
        isReadable in interface javax.ws.rs.ext.MessageBodyReader<org.reactivestreams.Publisher<?>>
      • readFrom

        public org.reactivestreams.Publisher<?> readFrom​(Class<org.reactivestreams.Publisher<?>> type,
                                                         Type genericType,
                                                         Annotation[] annotations,
                                                         javax.ws.rs.core.MediaType mediaType,
                                                         javax.ws.rs.core.MultivaluedMap<String,​String> httpHeaders,
                                                         InputStream entityStream)
                                                  throws IOException,
                                                         javax.ws.rs.WebApplicationException
        Specified by:
        readFrom in interface javax.ws.rs.ext.MessageBodyReader<org.reactivestreams.Publisher<?>>
        Throws:
        IOException
        javax.ws.rs.WebApplicationException