stream reactive fixed

6 years ago · e8d01fd220
parent 437d1db8f8
commit e8d01fd220
1 changed files with 1 additions and 2 deletions
--- 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