diff --git a/redisson/src/main/java/org/redisson/reactive/RedissonStreamReactive.java b/redisson/src/main/java/org/redisson/reactive/RedissonStreamReactive.java index 63bf86dd4..976cb7669 100644 --- a/redisson/src/main/java/org/redisson/reactive/RedissonStreamReactive.java +++ b/redisson/src/main/java/org/redisson/reactive/RedissonStreamReactive.java @@ -18,6 +18,7 @@ package org.redisson.reactive; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; +import java.util.function.Supplier; import org.reactivestreams.Publisher; import org.redisson.RedissonStream; @@ -31,8 +32,6 @@ import org.redisson.api.StreamId; import org.redisson.client.codec.Codec; import org.redisson.command.CommandReactiveExecutor; -import reactor.fn.Supplier; - /** * * @author Nikita Koksharov