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);