DATAREDIS-1178 - Pass ScanOptions on to connection.sScan when using ReactiveSetOperations.

This commit is contained in:
Christoph Strobl
2020-07-06 14:02:57 +02:00
parent dd790bc5ee
commit 488e658f5d

View File

@@ -430,7 +430,7 @@ class DefaultReactiveSetOperations<K, V> implements ReactiveSetOperations<K, V>
Assert.notNull(key, "Key must not be null!");
Assert.notNull(options, "ScanOptions must not be null!");
return createFlux(connection -> connection.sScan(rawKey(key)).map(this::readValue));
return createFlux(connection -> connection.sScan(rawKey(key), options).map(this::readValue));
}
/*