netty-pull
a socket pull-stream based on java nio.
dependency
<dependency>
<groupId>com.zmannotes</groupId>
<artifactId>socket-pull</artifactId>
<version>2.1.2</version>
</dependency>
example
Client
new SocketClient(eventLoop)
.onConnected(duplex->pull(source, duplex, sink))
.onDisconnected(()-> log.info("disconnected"))
.onThrowable(Throwable::printStackTrace)
.connect("localhost", 8081);