From e8d01fd22043bc2ae0261af39c933223385aca5b Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 17 Sep 2018 17:24:56 +0300 Subject: [PATCH] stream reactive fixed --- .../java/org/redisson/reactive/RedissonStreamReactive.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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