Package org.infinispan.rest.stream

Class CacheChunkedStream<T>

java.lang.Object
org.infinispan.rest.stream.CacheChunkedStream<T>
Direct Known Subclasses:
CacheEntryStreamProcessor, CacheKeyStreamProcessor
public abstract class CacheChunkedStream<T> extends Object

  • Field Details

    • logger

      protected static final org.infinispan.util.logging.Log logger

    • publisher

      protected final org.reactivestreams.Publisher<T> publisher

  • Constructor Details

    • CacheChunkedStream

      public CacheChunkedStream(org.reactivestreams.Publisher<T> publisher)

  • Method Details

    • readContentAsBytes

      public static byte[] readContentAsBytes(Object content)

    • subscribe

      public abstract void subscribe(io.netty.channel.ChannelHandlerContext ctx)