multiplex pull

A multiplex implementation that uses pull-stream .

License	The Apache License, Version 2.0
GroupId	com.zmannotes
ArtifactId	multiplex-pull
Last Version	2.1.3
Release Date	Dec 8, 2019
Type	jar
Description	multiplex pull A multiplex implementation that uses pull-stream .
Project URL	https://github.com/zman2013/multiplex-pull
Source Code Management	https://github.com/zman2013/multiplex-pull

Download multiplex-pull

Filename	Size
multiplex-pull-2.1.3.pom
multiplex-pull-2.1.3.jar	14 KB
multiplex-pull-2.1.3-sources.jar	10 KB
multiplex-pull-2.1.3-javadoc.jar	85 KB

How to add to project

Apache Maven

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

Gradle Groovy

// https://jarcasting.com/artifacts/com.zmannotes/multiplex-pull/
implementation 'com.zmannotes:multiplex-pull:2.1.3'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.zmannotes/multiplex-pull/
implementation ("com.zmannotes:multiplex-pull:2.1.3")

Apache Buildr

'com.zmannotes:multiplex-pull:jar:2.1.3'

Apache Ivy

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

Groovy Grape

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

Scala SBT

libraryDependencies += "com.zmannotes" % "multiplex-pull" % "2.1.3"

Leiningen

[com.zmannotes/multiplex-pull "2.1.3"]

Dependencies

compile (1)

Group / Artifact	Type	Version
com.zmannotes.stream : pull-stream	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	0.0.2

Project Modules

There are no modules declared in this project.

multiplex-pull

combine multiple pull-streams into one share underlying stream, such as one socket-pull stream can support many duplexes.

dependency

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

example

IDuplex<byte[]> duplex = new DefaultDuplex<>();

IMultiplex ma = new DefaultMultiplex()
        .onAccept(channel -> {
            link(channel.duplex(), duplex);
        });

IMultiplex mb = new DefaultMultiplex();

link(ma.duplex(), mb.duplex());

// you can create many channels based on one multiplex
IChannel channelB = mb.createChannel("food-model");
ISource<byte[]> source = new DefaultSource<>();
pull(source, channelB.duplex());

Versions

Version
2.1.3 Dec 8, 2019
2.1.2 Dec 8, 2019
1.0.2 Dec 7, 2019