Added ReactiveSocketFactory interface

rsocket · Mar 23, 2016 · 3503369 · 3503369
1 parent a0b550a
commit 3503369
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/main/java/io/reactivesocket/ReactiveSocketFactory.java b/src/main/java/io/reactivesocket/ReactiveSocketFactory.java
@@ -0,0 +1,11 @@
+package io.reactivesocket;
+
+import org.reactivestreams.Publisher;
+
+import java.net.SocketAddress;
+import java.util.concurrent.TimeUnit;
+
+@FunctionalInterface
+public interface ReactiveSocketFactory {
+    Publisher<ReactiveSocket> call(SocketAddress address, long timeout, TimeUnit timeUnit);
+}