netty-pull

an implementation of pull-stream based on netty.

License	The Apache License, Version 2.0
Categories	Net Netty Networking
GroupId	com.zmannotes
ArtifactId	netty-pull
Last Version	2.1.4
Release Date	Dec 9, 2019
Type	jar
Description	netty-pull an implementation of pull-stream based on netty.
Project URL	https://github.com/zman2013/netty-pull
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

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.zmannotes/netty-pull/ -->
<dependency>
    <groupId>com.zmannotes</groupId>
    <artifactId>netty-pull</artifactId>
    <version>2.1.4</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.zmannotes/netty-pull/
implementation 'com.zmannotes:netty-pull:2.1.4'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.zmannotes/netty-pull/
implementation ("com.zmannotes:netty-pull:2.1.4")

Apache Buildr

'com.zmannotes:netty-pull:jar:2.1.4'

Apache Ivy

<dependency org="com.zmannotes" name="netty-pull" rev="2.1.4">
  <artifact name="netty-pull" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.zmannotes', module='netty-pull', version='2.1.4')
)

Scala SBT

libraryDependencies += "com.zmannotes" % "netty-pull" % "2.1.4"

Leiningen

[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.

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 Dec 9, 2019
2.1.3 Dec 8, 2019
2.1.2 Dec 8, 2019
2.1.0 Dec 8, 2019
0.0.2 Dec 1, 2019