Class CacheKeyStreamProcessor

java.lang.Object
org.infinispan.rest.stream.CacheChunkedStream<byte[]>
org.infinispan.rest.stream.CacheKeyStreamProcessor

public class CacheKeyStreamProcessor extends CacheChunkedStream<byte[]>
A CacheChunkedStream that reads from a byte[] and produces a JSON output.
Since:
10.0
  • Constructor Details

    • CacheKeyStreamProcessor

      public CacheKeyStreamProcessor(org.reactivestreams.Publisher<byte[]> publisher)
  • Method Details

    • subscribe

      public void subscribe(io.netty.channel.ChannelHandlerContext ctx)
      Specified by:
      subscribe in class CacheChunkedStream<byte[]>