JarCasting
JarCasting JarCasting

netty-pull

an implementation of pull-stream based on netty.

License

License
Categories

Categories

Net Netty Networking
GroupId

GroupId

com.zmannotes
ArtifactId

ArtifactId

netty-pull
Last Version

Last Version

2.1.4
Release Date

Release Date
Type

Type

jar
Description

Description

netty-pull
an implementation of pull-stream based on netty.
Project URL

Project URL

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

Source Code Management

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

Download netty-pull

Filename Size
netty-pull-2.1.4.pom
netty-pull-2.1.4.jar 14 KB
netty-pull-2.1.4-sources.jar 7 KB
netty-pull-2.1.4-javadoc.jar 47 KB
Browse

How to add to project

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

Dependencies

compile (2)

Group / Artifact Type Version
com.zmannotes : net-pull jar 2.1.3
io.netty : netty-all jar 4.1.24.Final

test (3)

Group / Artifact Type Version
ch.qos.logback : logback-classic jar 1.2.3
junit : junit jar 4.12
org.mockito : mockito-core jar 3.1.0

Project Modules

There are no modules declared in this project.

Travis Build Coverage Status

netty-pull

a net-pull implementation based on netty.

dependency

<dependency>
    <groupId>com.zmannotes</groupId>
    <artifactId>netty-pull</artifactId>
    <version>2.1.3</version>
</dependency>

example

Server

new NettyServer()
        .onAccept((channelId,duplex) -> pull(duplex, duplex))
        .listen(8081);

Client

DefaultSink<ByteBuf> sink = new DefaultSink<>(System.out::println);

new NettyClient()
        .onConnected((channelId,duplex) -> pull( duplex, sink))
        .connect("localhost", 8081);

Versions

Version
2.1.4
2.1.3
2.1.2
2.1.0
0.0.2