Package redis.clients.jedis.util

Class JedisCommandIterationBase<B,D>

java.lang.Object
redis.clients.jedis.util.JedisCommandIterationBase<B,D>
Type Parameters:
B - Type of each batch reply
D - Type of each data
Direct Known Subclasses:
FtAggregateIteration, FtSearchIteration, ScanIteration
public abstract class JedisCommandIterationBase<B,D> extends Object

  • Field Details

    • builder

      private final Builder<B> builder

    • connections

      private final Queue<Map.Entry> connections

    • connection

      private Map.Entry connection

    • lastReply

      private B lastReply

    • roundRobinCompleted

      private boolean roundRobinCompleted

    • iterationCompleted

      private boolean iterationCompleted

  • Constructor Details

    • JedisCommandIterationBase

      protected JedisCommandIterationBase(ConnectionProvider connectionProvider, Builder<B> responseBuilder)

  • Method Details

    • isIterationCompleted

      public final boolean isIterationCompleted()

    • isNodeCompleted

      protected abstract boolean isNodeCompleted(B reply)

    • initCommandArguments

      protected abstract CommandArguments initCommandArguments()

    • nextCommandArguments

      protected abstract CommandArguments nextCommandArguments(B lastReply)

    • nextBatch

      public final B nextBatch()

    • convertBatchToData

      protected abstract Collection<D> convertBatchToData(B batch)

    • nextBatchList

      public final Collection<D> nextBatchList()

    • collect

      public final Collection<D> collect(Collection<D> c)