async/RedisClusterPubSubAsyncCommands.java

Provides an asynchronous and thread-safe API for executing Redis Cluster PubSub commands on specific upstream or replica nodes.

// Source: https://github.com/redis/lettuce | License: MIT | Copyright 2023-Present, Redis Ltd
// Provided via justclaw.it.com; keep this notice with the code.
package io.lettuce.core.cluster.pubsub.api.async;

import java.util.function.Predicate;

import io.lettuce.core.cluster.models.partitions.RedisClusterNode;
import io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection;
import io.lettuce.core.pubsub.api.async.RedisPubSubAsyncCommands;

/**
 * Asynchronous and thread-safe Redis Cluster PubSub API. Operations are executed either on the main connection or a
 * {@link PubSubAsyncNodeSelection}.
 *
 * @param <K> Key type.
 * @param <V> Value type.
 * @author Mark Paluch
 * @since 4.4
 */
public interface RedisClusterPubSubAsyncCommands<K, V> extends RedisPubSubAsyncCommands<K

... (truncated -- full source via MCP)