Constructor Detail

Method Detail

• lpopString

   final static String lpopString(RedisConnection $self, String key)

• lpopString

   final static List<String> lpopString(RedisConnection $self, String key, Long count)

• lpopString

   final static String lpopString(RedisConnectionPool $self, String key)

• lpopString

   final static List<String> lpopString(RedisConnectionPool $self, String key, Long count)

• lpopString

   final static Unit lpopString(RedisPipelineBuilder $self, String key, Function1<String, Unit> onResult)

  Parameters:

  onResult -

  • called with the first element, or null if the key does not exist

• lpopString

   final static Unit lpopString(RedisPipelineBuilder $self, String key, Long count, Function1<List<String>, Unit> onResult)

  Parameters:

  onResult -

  • called with up to count popped elements (empty if the key does not exist)

• lpopBytes

   final static ByteArray lpopBytes(RedisConnection $self, String key)

• lpopBytes

   final static List<ByteArray> lpopBytes(RedisConnection $self, String key, Long count)

• lpopBytes

   final static ByteArray lpopBytes(RedisConnectionPool $self, String key)

• lpopBytes

   final static List<ByteArray> lpopBytes(RedisConnectionPool $self, String key, Long count)

• lpopBytes

   final static Unit lpopBytes(RedisPipelineBuilder $self, String key, Function1<ByteArray, Unit> onResult)

• lpopBytes

   final static Unit lpopBytes(RedisPipelineBuilder $self, String key, Long count, Function1<List<ByteArray>, Unit> onResult)

• lpopStreaming

   final static Unit lpopStreaming(RedisConnection $self, String key, Function1<StreamWithLength, Unit> onResponse)

• lpopStreaming

   final static Unit lpopStreaming(RedisConnection $self, String key, Long count, ElementSink<StreamWithLength> sink)

• lpopStreaming

   final static Unit lpopStreaming(RedisPipelineBuilder $self, String key, Function1<StreamWithLength, Unit> onResponse)

• lpopStreaming

   final static Unit lpopStreaming(RedisPipelineBuilder $self, String key, Long count, ElementSink<StreamWithLength> sink)