diff --git a/src/main/java/org/springframework/data/redis/core/DefaultReactiveSetOperations.java b/src/main/java/org/springframework/data/redis/core/DefaultReactiveSetOperations.java index 70a09f4c1..60c84bbf1 100644 --- a/src/main/java/org/springframework/data/redis/core/DefaultReactiveSetOperations.java +++ b/src/main/java/org/springframework/data/redis/core/DefaultReactiveSetOperations.java @@ -430,7 +430,7 @@ class DefaultReactiveSetOperations implements ReactiveSetOperations 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)); } /*