public class GeoWithinListOutput<K,V> extends CommandOutput<K,V,List<GeoWithin<V>>> implements StreamingOutput<GeoWithin<V>>
GeoCoordinates's.StreamingOutput.Subscriber<T>codec, error, output| Constructor and Description |
|---|
GeoWithinListOutput(RedisCodec<K,V> codec,
boolean withDistance,
boolean withHash,
boolean withCoordinates) |
| Modifier and Type | Method and Description |
|---|---|
void |
complete(int depth)
Mark the command output complete.
|
StreamingOutput.Subscriber<GeoWithin<V>> |
getSubscriber()
Retrieves the
StreamingOutput.Subscriber. |
void |
set(ByteBuffer bytes)
Update the command output with a sequence of bytes, or
null. |
void |
set(double number)
Update the command output with a floating-point number.
|
void |
set(long integer)
Update the command output with a 64-bit signed integer.
|
void |
setSubscriber(StreamingOutput.Subscriber<GeoWithin<V>> subscriber)
Sets the
StreamingOutput.Subscriber. |
decodeAscii, get, getError, hasError, multi, multiArray, multiMap, multiPush, multiSet, set, setBigNumber, setError, setError, setSingle, toStringpublic GeoWithinListOutput(RedisCodec<K,V> codec, boolean withDistance, boolean withHash, boolean withCoordinates)
public void set(long integer)
CommandOutputCommandOutput implementations must override this
method to decode number (integer) response values.public void set(ByteBuffer bytes)
CommandOutputnull. Concrete CommandOutput implementations must
override this method to decode bulk/bytes response values.public void set(double number)
CommandOutputCommandOutput implementations must override this
method to decode double response values.public void complete(int depth)
CommandOutputpublic void setSubscriber(StreamingOutput.Subscriber<GeoWithin<V>> subscriber)
StreamingOutputStreamingOutput.Subscriber.setSubscriber in interface StreamingOutput<GeoWithin<V>>public StreamingOutput.Subscriber<GeoWithin<V>> getSubscriber()
StreamingOutputStreamingOutput.Subscriber.getSubscriber in interface StreamingOutput<GeoWithin<V>>Copyright © 2021 lettuce.io. All rights reserved.