Package cc.carm.plugin.mineredis.api.request

Class RedisRequestBuilder

java.lang.Object

cc.carm.plugin.mineredis.api.request.RedisRequestBuilder

public class RedisRequestBuilder
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.function.Predicate<RedisMessage>	filter
protected @NotNull RedisManager	redis
protected @NotNull java.lang.String	requestChannel
protected @NotNull com.google.common.io.ByteArrayDataOutput	requestData

Constructor Summary

Constructors

Constructor	Description
RedisRequestBuilder(@NotNull RedisManager redis, @NotNull java.lang.String requestChannel, @NotNull com.google.common.io.ByteArrayDataOutput requestData)

Method Summary

Modifier and Type	Method	Description
RedisRequestBuilder	filter(@NotNull java.util.function.Predicate<RedisMessage> filter)
<R> java.util.concurrent.CompletableFuture<R>	handleResponse(@NotNull java.lang.String channel, @NotNull java.util.function.Function<RedisMessage,R> handler)

Methods inherited from class java.lang.Object

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

Field Detail

redis

@NotNull
protected final @NotNull RedisManager redis

requestChannel

@NotNull
protected final @NotNull java.lang.String requestChannel

requestData

@NotNull
protected final @NotNull com.google.common.io.ByteArrayDataOutput requestData

filter

protected java.util.function.Predicate<RedisMessage> filter

Constructor Detail

RedisRequestBuilder

public RedisRequestBuilder(@NotNull
                           @NotNull RedisManager redis,
                           @NotNull
                           @NotNull java.lang.String requestChannel,
                           @NotNull
                           @NotNull com.google.common.io.ByteArrayDataOutput requestData)

Method Detail

filter

public RedisRequestBuilder filter(@NotNull
                                  @NotNull java.util.function.Predicate<RedisMessage> filter)

handleResponse

public <R> java.util.concurrent.CompletableFuture<R> handleResponse(@NotNull
                                                                    @NotNull java.lang.String channel,
                                                                    @NotNull
                                                                    @NotNull java.util.function.Function<RedisMessage,R> handler)