java socket-pull

socket pull stream implementation with java nio.

License

License

GroupId

GroupId

com.zmannotes
ArtifactId

ArtifactId

socket-pull
Last Version

Last Version

2.1.3
Release Date

Release Date

Type

Type

jar
Description

Description

java socket-pull
socket pull stream implementation with java nio.
Project URL

Project URL

https://github.com/zman2013/socket-pull
Source Code Management

Source Code Management

https://github.com/zman2013/socket-pull

Download socket-pull

How to add to project

<!-- https://jarcasting.com/artifacts/com.zmannotes/socket-pull/ -->
<dependency>
    <groupId>com.zmannotes</groupId>
    <artifactId>socket-pull</artifactId>
    <version>2.1.3</version>
</dependency>
// https://jarcasting.com/artifacts/com.zmannotes/socket-pull/
implementation 'com.zmannotes:socket-pull:2.1.3'
// https://jarcasting.com/artifacts/com.zmannotes/socket-pull/
implementation ("com.zmannotes:socket-pull:2.1.3")
'com.zmannotes:socket-pull:jar:2.1.3'
<dependency org="com.zmannotes" name="socket-pull" rev="2.1.3">
  <artifact name="socket-pull" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.zmannotes', module='socket-pull', version='2.1.3')
)
libraryDependencies += "com.zmannotes" % "socket-pull" % "2.1.3"
[com.zmannotes/socket-pull "2.1.3"]

Dependencies

compile (3)

Group / Artifact Type Version
com.zmannotes : event-loop jar 0.0.1
com.zmannotes.event : event-emitter jar 0.0.4
com.zmannotes : net-pull jar 2.1.3

test (5)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.16.16
ch.qos.logback : logback-classic jar 1.2.3
junit : junit jar 4.12
org.mockito : mockito-core jar 3.1.0
com.zmannotes : netty-pull jar 2.1.0

Project Modules

There are no modules declared in this project.

Travis Build Coverage Status

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

Versions

Version
2.1.3
2.1.2
2.1.0
0.0.1