Package org.infinispan.rest.stream

Class CacheEntryStreamProcessor

java.lang.Object

org.infinispan.rest.stream.CacheChunkedStream<CacheEntry<?,?>>

org.infinispan.rest.stream.CacheEntryStreamProcessor

public class CacheEntryStreamProcessor
extends CacheChunkedStream<CacheEntry<?,?>>

A CacheChunkedStream that reads Map.Entry and produces a JSON output. For example:

 [
   {"key":1,"value":"value","timeToLiveSeconds": -1, "maxIdleTimeSeconds": -1, "created": -1, "lastUsed": -1, "expireTime": -1},
   {"key":2,"value":"value2","timeToLiveSeconds": -1, "maxIdleTimeSeconds": -1, "created": -1, "lastUsed": -1, "expireTime": -1}
 ]
 

Since:

12.0

Field Summary

Fields inherited from class org.infinispan.rest.stream.CacheChunkedStream

logger, publisher

Constructor Summary

Constructors

Constructor	Description
CacheEntryStreamProcessor(org.reactivestreams.Publisher<CacheEntry<?,?>> publisher, boolean keysAreJson, boolean valuesAreJson, boolean includeMetadata)

Method Summary

Modifier and Type	Method	Description
void	subscribe(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class org.infinispan.rest.stream.CacheChunkedStream

readContentAsBytes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CacheEntryStreamProcessor

public CacheEntryStreamProcessor(org.reactivestreams.Publisher<CacheEntry<?,?>> publisher,
 boolean keysAreJson,
 boolean valuesAreJson,
 boolean includeMetadata)

Method Details

subscribe

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

Specified by:

subscribe in class CacheChunkedStream<CacheEntry<?,?>>