クラス ReactiveStreamCommands.ReadCommand
java.lang.ObjectSE
org.springframework.data.redis.connection.ReactiveStreamCommands.ReadCommand
- 含まれているインターフェース:
- ReactiveStreamCommands
XRANGE/XREVRANGE コマンドパラメーター。コンストラクター概要
コンストラクターコンストラクター説明ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, StreamReadOptions readOptions, Consumer consumer) 方法の概要
修飾子と型メソッド説明Consumerを適用します。from(StreamOffset<ByteBufferSE> streamOffset) StreamOffsetを指定して新しいReactiveStreamCommands.ReadCommandを作成します。from(StreamOffset<ByteBufferSE>... streamOffsets) StreamOffsetを指定して、新しいReactiveStreamCommands.ReadCommandを作成します。withOptions(StreamReadOptions options) 指定されたStreamReadOptionsを適用します。
コンストラクターの詳細
ReadCommand
public ReadCommand(ListSE<StreamOffset<ByteBufferSE>> streamOffsets, @Nullable StreamReadOptions readOptions, @Nullable Consumer consumer) - パラメーター:
streamOffsets- null であってはなりません。readOptions-consumer-
方法の詳細
from
StreamOffsetを指定して新しいReactiveStreamCommands.ReadCommandを作成します。- パラメーター:
streamOffset- null であってはなりません。- 戻り値:
StreamOffset用の新しいReactiveStreamCommands.ReadCommand。
from
StreamOffsetを指定して、新しいReactiveStreamCommands.ReadCommandを作成します。- パラメーター:
streamOffsets- null であってはなりません。- 戻り値:
StreamOffset用の新しいReactiveStreamCommands.ReadCommand。
as
Consumerを適用します。以前に構成されたすべてのプロパティを使用して、新しいコマンドインスタンスを構築します。- パラメーター:
consumer- null であってはなりません。- 戻り値:
Consumerが適用された新しいReactiveStreamCommands.ReadCommand。
withOptions
指定されたStreamReadOptionsを適用します。以前に構成されたすべてのプロパティを使用して、新しいコマンドインスタンスを構築します。- パラメーター:
options- null であってはなりません。- 戻り値:
Consumerが適用された新しいReactiveStreamCommands.ReadCommand。
getStreamOffsets
getReadOptions
getConsumer