インターフェース ReactiveListCommands
- 既知のすべてのサブインターフェース:
ReactiveClusterListCommands
public interface ReactiveListCommands
Redis リアクティブインフラストラクチャを使用して実行されるコマンドを一覧表示します。
- 導入:
- 2.0
- 作成者:
- Christoph Strobl, Mark Paluch, dengliming
ネストされたクラスの概要
ネストされたクラス修飾子と型インターフェース説明static classBLMOVEコマンドパラメーター。static classstatic classBRPOPLPUSHコマンドパラメーター。static enumstatic classLINDEXコマンドパラメーター。static classLINSERTコマンドパラメーター。static classLMOVEコマンドパラメーター。static classLPOSコマンドパラメーター。static classLREMコマンドパラメーター。static classLSETコマンドパラメーター。static classLPOP/RPOP コマンドパラメーター。static classstatic classstatic classLPUSH/RPUSH コマンドパラメーター。static classRPOPLPUSHコマンドパラメーター。方法の概要
修飾子と型メソッド説明default reactor.core.publisher.Mono<ByteBufferSE>bLMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to, DurationSE timeout) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>>bLMove(org.reactivestreams.Publisher<ReactiveListCommands.BLMoveCommand> commands) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。default reactor.core.publisher.Mono<ReactiveListCommands.PopResult>blPop(ListSE<ByteBufferSE> keys, DurationSE timeout) キーに保存されているリストから最初の要素を削除して返します。reactor.core.publisher.Flux<ReactiveListCommands.PopResponse>bPop(org.reactivestreams.Publisher<ReactiveListCommands.BPopCommand> commands) ReactiveListCommands.BPopCommand.getKeys()に格納されているリストから最上位のReactiveListCommands.BPopCommand.getDirection()要素を削除して返します。
要素が使用可能になるか、ReactiveListCommands.BPopCommand.getTimeout()に到達するまで、 接続をブロックします。default reactor.core.publisher.Mono<ReactiveListCommands.PopResult>brPop(ListSE<ByteBufferSE> keys, DurationSE timeout) キーに保存されているリストから最後の要素を削除して返します。default reactor.core.publisher.Mono<ByteBufferSE>bRPopLPush(ByteBufferSE source, ByteBufferSE destination, DurationSE timeout) ソースのリストから最後の要素を削除し、それを宛先に追加して、その値を返します。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>>bRPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.BRPopLPushCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから最後の要素を削除し、それをReactiveListCommands.BRPopLPushCommand.getDestination()に追加して、その値を返します。default reactor.core.publisher.Mono<ByteBufferSE>lIndex(ByteBufferSE key, long index) キーのインデックスフォームリストで要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>>lIndex(org.reactivestreams.Publisher<ReactiveListCommands.LIndexCommand> commands) default reactor.core.publisher.Mono<LongSE>lInsert(ByteBufferSE key, RedisListCommands.Position position, ByteBufferSE pivot, ByteBufferSE value) キーの値RedisListCommands.Position.BEFOREまたはRedisListCommands.Position.AFTER既存のピボットを挿入します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,LongSE>> lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands) default reactor.core.publisher.Mono<LongSE>lLen(ByteBufferSE key) キーに保存されているリストのサイズを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストのサイズを取得しますdefault reactor.core.publisher.Mono<ByteBufferSE>lMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>>lMove(org.reactivestreams.Publisher<? extends ReactiveListCommands.LMoveCommand> commands) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。default reactor.core.publisher.Mono<ByteBufferSE>lPop(ByteBufferSE key) キーに保存されているリストの最初の要素を削除して返します。default reactor.core.publisher.Flux<ByteBufferSE>lPop(ByteBufferSE key, long count) キーに格納されているリストの最初のcount要素を削除して返します。default reactor.core.publisher.Mono<LongSE>lPos(ByteBufferSE key, ByteBufferSE element) キーのリストから要素の最初のインデックスを取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,LongSE>> lPos(org.reactivestreams.Publisher<ReactiveListCommands.LPosCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから要素のインデックスを取得します。default reactor.core.publisher.Flux<LongSE>lPos(ReactiveListCommands.LPosCommand command) ReactiveRedisConnection.KeyCommand.getKey()のリストから要素のインデックスを取得します。default reactor.core.publisher.Mono<LongSE>lPush(ByteBufferSE key, ListSE<ByteBufferSE> values) キーの前に値を追加します。default reactor.core.publisher.Mono<LongSE>lPushX(ByteBufferSE key, ByteBufferSE value) キーがすでに存在する場合は、キーの前に値を追加します。default reactor.core.publisher.Flux<ByteBufferSE>lRange(ByteBufferSE key, long start, long end) キーのリストから開始と終了の間の要素を取得します。reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBufferSE>>> lRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) default reactor.core.publisher.Mono<LongSE>lRem(ByteBufferSE key, LongSE count, ByteBufferSE value) キーに保存されているリストから、値の最初のカウント出現箇所を削除します。default reactor.core.publisher.Mono<LongSE>lRem(ByteBufferSE key, ByteBufferSE value) キーに保存されているリストからすべての値を削除します。reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,LongSE>> lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands) default reactor.core.publisher.Mono<BooleanSE>lSet(ByteBufferSE key, long index, ByteBufferSE value) 値リスト要素をインデックスに設定します。reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>>lSet(org.reactivestreams.Publisher<ReactiveListCommands.LSetCommand> commands) default reactor.core.publisher.Mono<BooleanSE>lTrim(ByteBufferSE key, long start, long end) 開始と終了の間の要素のキーでリストをトリムします。reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>>lTrim(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>>pop(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストの最後の要素を削除して返しますreactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBufferSE>>> popList(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストの最後の要素を削除して返しますreactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,LongSE>> push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands) default reactor.core.publisher.Mono<ByteBufferSE>rPop(ByteBufferSE key) キーに保存されているリストの最後の要素を削除して返します。default reactor.core.publisher.Flux<ByteBufferSE>rPop(ByteBufferSE key, long count) キーに保存されているリストの最後のcount要素を削除して返します。default reactor.core.publisher.Mono<ByteBufferSE>rPopLPush(ByteBufferSE source, ByteBufferSE destination) ソースのリストから最後の要素を削除し、それを宛先に追加して、その値を返します。reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>>rPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.RPopLPushCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから最後の要素を削除し、それをReactiveListCommands.RPopLPushCommand.getDestination()に追加して、その値を返します。default reactor.core.publisher.Mono<LongSE>rPush(ByteBufferSE key, ListSE<ByteBufferSE> values) キーに値を追加します。default reactor.core.publisher.Mono<LongSE>rPushX(ByteBufferSE key, ByteBufferSE value) キーがすでに存在する場合にのみ、キーに値を追加します。
方法の詳細
rPush
キーに値を追加します。- パラメーター:
key- null であってはなりません。values- null であってはなりません。- 戻り値:
- 関連事項:
rPushX
キーがすでに存在する場合にのみ、キーに値を追加します。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
lPush
キーの前に値を追加します。- パラメーター:
key- null であってはなりません。values- null であってはなりません。- 戻り値:
- 関連事項:
lPushX
キーがすでに存在する場合は、キーの前に値を追加します。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
push
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,LongSE>> push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands) ReactiveListCommands.PushCommand.getValues()をReactiveRedisConnection.KeyCommand.getKey()の前に追加します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lLen
キーに保存されているリストのサイズを取得します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
lLen
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,LongSE>> lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストのサイズを取得します- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lRange
キーのリストから開始と終了の間の要素を取得します。- パラメーター:
key- null であってはなりません。start-end-- 戻り値:
- 関連事項:
lRange
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBufferSE>>> lRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストからReactiveRedisConnection.RangeCommand.getRange()の要素を取得します- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lTrim
開始と終了の間の要素のキーでリストをトリムします。- パラメーター:
key- null であってはなりません。start-end-- 戻り値:
- 関連事項:
lTrim
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>> lTrim(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストをReactiveRedisConnection.RangeCommand.getRange()内の要素にトリムします。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lPos
キーのリストから要素の最初のインデックスを取得します。- パラメーター:
key- null であってはなりません。element-- 戻り値:
- 要素インデックスを発行する
Mono。 - 導入:
- 2.4
- 関連事項:
lPos
ReactiveRedisConnection.KeyCommand.getKey()のリストから要素のインデックスを取得します。- パラメーター:
command- null であってはなりません。- 戻り値:
- 要素インデックスを 1 つずつ放出する
Flux。 - 導入:
- 2.4
- 関連事項:
lPos
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,LongSE>> lPos(org.reactivestreams.Publisher<ReactiveListCommands.LPosCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから要素のインデックスを取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 要素インデックスを 1 つずつ放出する
Flux。 - 導入:
- 2.4
- 関連事項:
lIndex
キーのインデックスフォームリストで要素を取得します。- パラメーター:
key- null であってはなりません。index-- 戻り値:
- 関連事項:
lIndex
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>> lIndex(org.reactivestreams.Publisher<ReactiveListCommands.LIndexCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のReactiveListCommands.LIndexCommand.getIndex()フォームリストで要素を取得します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lInsert
default reactor.core.publisher.Mono<LongSE> lInsert(ByteBufferSE key, RedisListCommands.Position position, ByteBufferSE pivot, ByteBufferSE value) キーの値RedisListCommands.Position.BEFOREまたはRedisListCommands.Position.AFTER既存のピボットを挿入します。- パラメーター:
key- null であってはなりません。position- null であってはなりません。pivot- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
lInsert
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,LongSE>> lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()用のReactiveListCommands.LInsertCommand.getValue()RedisListCommands.Position.BEFOREまたはRedisListCommands.Position.AFTER既存のReactiveListCommands.LInsertCommand.getPivot()を挿入します- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lMove
default reactor.core.publisher.Mono<ByteBufferSE> lMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。- パラメーター:
sourceKey- null であってはなりません。destinationKey- null であってはなりません。from- null であってはなりません。to- null であってはなりません。- 戻り値:
- 導入:
- 2.6
- 関連事項:
lMove
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>> lMove(org.reactivestreams.Publisher<? extends ReactiveListCommands.LMoveCommand> commands) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 導入:
- 2.6
- 関連事項:
bLMove
default reactor.core.publisher.Mono<ByteBufferSE> bLMove(ByteBufferSE sourceKey, ByteBufferSE destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to, DurationSE timeout) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。- パラメーター:
sourceKey- null であってはなりません。destinationKey- null であってはなりません。from- null であってはなりません。to- null であってはなりません。timeout-- 戻り値:
- 導入:
- 2.6
- 関連事項:
bLMove
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>> bLMove(org.reactivestreams.Publisher<ReactiveListCommands.BLMoveCommand> commands) sourceKeyに格納されたリストの最初 / 最後の要素 (引数fromに応じてヘッド / テール) をアトミックに 返して削除し、destinationKeyに格納されたリストの最初 / 最後の要素 (引数toに応じてヘッド / テール) に要素をプッシュします。要素が使用可能になるか、
timeoutに達するまで、 接続をブロックします。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 導入:
- 2.6
- 関連事項:
lSet
default reactor.core.publisher.Mono<BooleanSE> lSet(ByteBufferSE key, long index, ByteBufferSE value) 値リスト要素をインデックスに設定します。- パラメーター:
key- null であってはなりません。index-value- null であってはなりません。- 戻り値:
- 関連事項:
lSet
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>> lSet(org.reactivestreams.Publisher<ReactiveListCommands.LSetCommand> commands) ReactiveListCommands.LSetCommand.getValue()リスト要素をReactiveRedisConnection.KeyCommand.getKey()に設定します。- パラメーター:
commands-- 戻り値:
- 関連事項:
lRem
キーに保存されているリストからすべての値を削除します。- パラメーター:
key- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
lRem
default reactor.core.publisher.Mono<LongSE> lRem(ByteBufferSE key, LongSE count, ByteBufferSE value) キーに保存されているリストから、値の最初のカウント出現箇所を削除します。- パラメーター:
key- null であってはなりません。count- null であってはなりません。value- null であってはなりません。- 戻り値:
- 関連事項:
lRem
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,LongSE>> lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に格納されているリストからReactiveListCommands.LRemCommand.getValue()のReactiveListCommands.LRemCommand.getCount()出現箇所を削除します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
lPop
キーに保存されているリストの最初の要素を削除して返します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
lPop
キーに格納されているリストの最初のcount要素を削除して返します。- パラメーター:
key- null であってはなりません。count-- 戻り値:
- 導入:
- 2.6
- 関連事項:
rPop
キーに保存されているリストの最後の要素を削除して返します。- パラメーター:
key- null であってはなりません。- 戻り値:
- 関連事項:
rPop
キーに保存されているリストの最後のcount要素を削除して返します。- パラメーター:
key- null であってはなりません。count-- 戻り値:
- 導入:
- 2.6
- 関連事項:
pop
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>> pop(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストの最後の要素を削除して返します- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
popList
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBufferSE>>> popList(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()に保存されているリストの最後の要素を削除して返します- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
blPop
default reactor.core.publisher.Mono<ReactiveListCommands.PopResult> blPop(ListSE<ByteBufferSE> keys, DurationSE timeout) キーに保存されているリストから最初の要素を削除して返します。
要素が使用可能になるか、タイムアウトに達するまで接続をブロックします。- パラメーター:
keys- null であってはなりません。timeout- null であってはなりません。- 戻り値:
- 関連事項:
brPop
default reactor.core.publisher.Mono<ReactiveListCommands.PopResult> brPop(ListSE<ByteBufferSE> keys, DurationSE timeout) キーに保存されているリストから最後の要素を削除して返します。
要素が使用可能になるか、タイムアウトに達するまで接続をブロックします。- パラメーター:
keys- null であってはなりません。timeout- null であってはなりません。- 戻り値:
- 関連事項:
bPop
reactor.core.publisher.Flux<ReactiveListCommands.PopResponse> bPop(org.reactivestreams.Publisher<ReactiveListCommands.BPopCommand> commands) ReactiveListCommands.BPopCommand.getKeys()に格納されているリストから最上位のReactiveListCommands.BPopCommand.getDirection()要素を削除して返します。
要素が使用可能になるか、ReactiveListCommands.BPopCommand.getTimeout()に到達するまで、 接続をブロックします。- パラメーター:
commands-- 戻り値:
- 関連事項:
rPopLPush
default reactor.core.publisher.Mono<ByteBufferSE> rPopLPush(ByteBufferSE source, ByteBufferSE destination) ソースのリストから最後の要素を削除し、それを宛先に追加して、その値を返します。- パラメーター:
source- null であってはなりません。destination- null であってはなりません。- 戻り値:
- 関連事項:
rPopLPush
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>> rPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.RPopLPushCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから最後の要素を削除し、それをReactiveListCommands.RPopLPushCommand.getDestination()に追加して、その値を返します。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項:
bRPopLPush
default reactor.core.publisher.Mono<ByteBufferSE> bRPopLPush(ByteBufferSE source, ByteBufferSE destination, DurationSE timeout) ソースのリストから最後の要素を削除し、それを宛先に追加して、その値を返します。要素が利用可能になるかタイムアウトになるまで接続をブロックします。- パラメーター:
source- null であってはなりません。destination- null であってはなりません。- 戻り値:
- 関連事項:
bRPopLPush
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>> bRPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.BRPopLPushCommand> commands) ReactiveRedisConnection.KeyCommand.getKey()のリストから最後の要素を削除し、それをReactiveListCommands.BRPopLPushCommand.getDestination()に追加して、その値を返します。
要素が利用可能になるか、ReactiveListCommands.BRPopLPushCommand.getTimeout()に到達するまで、 接続をブロックします。- パラメーター:
commands- null であってはなりません。- 戻り値:
- 関連事項: