Uses of Class
zmq.pipe.Pipe

Packages that use Pipe

Package	Description
zmq	Provides low-level bindings for ØMQ.
zmq.io
zmq.pipe
zmq.socket
zmq.socket.clientserver
zmq.socket.pipeline
zmq.socket.pubsub
zmq.socket.radiodish
zmq.socket.reqrep
zmq.socket.scattergather

Uses of Pipe in zmq

Fields in zmq declared as Pipe

Modifier and Type	Field	Description
private Pipe	Ctx.PendingConnection.bindPipe
private Pipe	Ctx.PendingConnection.connectPipe
private Pipe	SocketBase.EndpointPipe.pipe

Fields in zmq with type parameters of type Pipe

Modifier and Type	Field	Description
private MultiMap<java.lang.String,Pipe>	SocketBase.inprocs
private java.util.Set<Pipe>	SocketBase.pipes

Methods in zmq with parameters of type Pipe

Modifier and Type	Method	Description
private void	SocketBase.addEndpoint(java.lang.String addr, Own endpoint, Pipe pipe)
private void	SocketBase.attachPipe(Pipe pipe, boolean isLocallyInitiated)
private void	SocketBase.attachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void	SocketBase.hiccuped(Pipe pipe)
(package private) void	Ctx.pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
protected void	ZObject.pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
void	SocketBase.pipeTerminated(Pipe pipe)
protected void	SocketBase.processBind(Pipe pipe)
protected void	ZObject.processBind(Pipe pipe)
void	SocketBase.readActivated(Pipe pipe)
protected void	ZObject.sendActivateRead(Pipe destination)
protected void	ZObject.sendActivateWrite(Pipe destination, long msgsRead)
protected void	ZObject.sendBind(Own destination, Pipe pipe)
protected void	ZObject.sendBind(Own destination, Pipe pipe, boolean incSeqnum)
protected void	ZObject.sendHiccup(Pipe destination, YPipeBase<Msg> pipe)
protected void	ZObject.sendPipeTerm(Pipe destination)
protected void	ZObject.sendPipeTermAck(Pipe destination)
void	SocketBase.writeActivated(Pipe pipe)
protected abstract void	SocketBase.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	SocketBase.xhiccuped(Pipe pipe)
protected abstract void	SocketBase.xpipeTerminated(Pipe pipe)
protected void	SocketBase.xreadActivated(Pipe pipe)
protected void	SocketBase.xwriteActivated(Pipe pipe)

Constructors in zmq with parameters of type Pipe

Constructor	Description
EndpointPipe(Own endpoint, Pipe pipe)
PendingConnection(Ctx.Endpoint endpoint, Pipe connectPipe, Pipe bindPipe)

Uses of Pipe in zmq.io

Fields in zmq.io declared as Pipe

Modifier and Type	Field	Description
private Pipe	SessionBase.pipe
private Pipe	SessionBase.zapPipe

Fields in zmq.io with type parameters of type Pipe

Modifier and Type	Field	Description
private java.util.Set<Pipe>	SessionBase.terminatingPipes

Methods in zmq.io with parameters of type Pipe

Modifier and Type	Method	Description
void	SessionBase.attachPipe(Pipe pipe)
void	SessionBase.hiccuped(Pipe pipe)
void	SessionBase.pipeTerminated(Pipe pipe)
void	SessionBase.readActivated(Pipe pipe)
void	SessionBase.writeActivated(Pipe pipe)

Uses of Pipe in zmq.pipe

Fields in zmq.pipe declared as Pipe

Modifier and Type	Field	Description
private Pipe	Pipe.peer

Methods in zmq.pipe that return Pipe

Modifier and Type	Method	Description
static Pipe[]	Pipe.pair(ZObject[] parents, int[] hwms, boolean[] conflates)

Methods in zmq.pipe with parameters of type Pipe

Modifier and Type	Method	Description
void	Pipe.IPipeEvents.hiccuped(Pipe pipe)
void	Pipe.IPipeEvents.pipeTerminated(Pipe pipe)
void	Pipe.IPipeEvents.readActivated(Pipe pipe)
private void	Pipe.setPeer(Pipe peer)
void	Pipe.IPipeEvents.writeActivated(Pipe pipe)

Uses of Pipe in zmq.socket

Fields in zmq.socket declared as Pipe

Modifier and Type	Field	Description
private Pipe	Stream.currentOut
private Pipe	Channel.lastIn
private Pipe	FQ.lastIn
private Pipe	Pair.lastIn
private Pipe	Channel.pipe
private Pipe	Pair.pipe
private Pipe	Stream.Outpipe.pipe

Fields in zmq.socket with type parameters of type Pipe

Modifier and Type	Field	Description
private java.util.List<Pipe>	FQ.pipes
private java.util.List<Pipe>	LB.pipes

Methods in zmq.socket with parameters of type Pipe

Modifier and Type	Method	Description
void	FQ.activated(Pipe pipe)
void	LB.activated(Pipe pipe)
void	FQ.attach(Pipe pipe)
void	LB.attach(Pipe pipe)
private void	Stream.identifyPeer(Pipe pipe, boolean isLocallyInitiated)
void	FQ.terminated(Pipe pipe)
void	LB.terminated(Pipe pipe)
protected void	Channel.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Pair.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void	Peer.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Stream.xattachPipe(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated)
protected void	Channel.xpipeTerminated(Pipe pipe)
protected void	Pair.xpipeTerminated(Pipe pipe)
protected void	Stream.xpipeTerminated(Pipe pipe)
protected void	Channel.xreadActivated(Pipe pipe)
protected void	Pair.xreadActivated(Pipe pipe)
protected void	Stream.xreadActivated(Pipe pipe)
protected void	Channel.xwriteActivated(Pipe pipe)
protected void	Pair.xwriteActivated(Pipe pipe)
protected void	Stream.xwriteActivated(Pipe pipe)

Method parameters in zmq.socket with type arguments of type Pipe

Modifier and Type	Method	Description
Msg	FQ.recvPipe(Errno errno, ValueReference<Pipe> pipe)
boolean	LB.sendpipe(Msg msg, Errno errno, ValueReference<Pipe> pipe)

Constructors in zmq.socket with parameters of type Pipe

Constructor	Description
Outpipe(Pipe pipe, boolean active)

Uses of Pipe in zmq.socket.clientserver

Fields in zmq.socket.clientserver declared as Pipe

Modifier and Type	Field	Description
private Pipe	Server.Outpipe.pipe

Methods in zmq.socket.clientserver with parameters of type Pipe

Modifier and Type	Method	Description
protected void	Client.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void	Server.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Client.xpipeTerminated(Pipe pipe)
void	Server.xpipeTerminated(Pipe pipe)
protected void	Client.xreadActivated(Pipe pipe)
void	Server.xreadActivated(Pipe pipe)
protected void	Client.xwriteActivated(Pipe pipe)
void	Server.xwriteActivated(Pipe pipe)

Constructors in zmq.socket.clientserver with parameters of type Pipe

Constructor	Description
Outpipe(Pipe pipe, boolean active)

Uses of Pipe in zmq.socket.pipeline

Methods in zmq.socket.pipeline with parameters of type Pipe

Modifier and Type	Method	Description
protected void	Pull.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Push.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Pull.xpipeTerminated(Pipe pipe)
protected void	Push.xpipeTerminated(Pipe pipe)
protected void	Pull.xreadActivated(Pipe pipe)
protected void	Push.xwriteActivated(Pipe pipe)

Uses of Pipe in zmq.socket.pubsub

Fields in zmq.socket.pubsub declared as Pipe

Modifier and Type	Field	Description
private Pipe	XPub.lastPipe

Fields in zmq.socket.pubsub with type parameters of type Pipe

Modifier and Type	Field	Description
private java.util.Deque<Pipe>	XPub.pendingPipes
private java.util.List<Pipe>	Dist.pipes
private java.util.Set<Pipe>	Mtrie.pipes

Methods in zmq.socket.pubsub with parameters of type Pipe

Modifier and Type	Method	Description
void	Dist.activated(Pipe pipe)
boolean	Mtrie.add(Msg msg, Pipe pipe)
void	Trie.ITrieHandler.added(byte[] data, int size, Pipe arg)
void	XSub.SendSubscription.added(byte[] data, int size, Pipe pipe)
private boolean	Mtrie.addHelper(Msg msg, int start, int size, Pipe pipe)
(package private) boolean	Mtrie.addOnTop(Pipe pipe)
void	Trie.apply(Trie.ITrieHandler func, Pipe arg)
private void	Trie.applyHelper(byte[] buff, int buffsize, int maxBuffsize, Trie.ITrieHandler func, Pipe pipe)
void	Dist.attach(Pipe pipe)
void	Mtrie.IMtrieHandler.invoke(Pipe pipe, byte[] data, int size, XPub arg)
void	XPub.MarkAsMatching.invoke(Pipe pipe, byte[] data, int size, XPub self)
void	XPub.SendUnsubscription.invoke(Pipe pipe, byte[] data, int size, XPub self)
private void	XPub.markAsMatching(Pipe pipe)
void	Dist.match(Pipe pipe)
boolean	Mtrie.rm(Msg msg, Pipe pipe)
boolean	Mtrie.rm(Pipe pipe, Mtrie.IMtrieHandler func, XPub pub)
private boolean	Mtrie.rmHelper(Msg msg, int start, int size, Pipe pipe)
private boolean	Mtrie.rmHelper(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, XPub pub)
private boolean	XSub.sendSubscription(byte[] data, int size, Pipe pipe)
void	Dist.terminated(Pipe pipe)
private boolean	Dist.write(Pipe pipe, Msg msg)
protected void	Pub.xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
protected void	XPub.xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
protected void	XSub.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	XSub.xhiccuped(Pipe pipe)
protected void	XPub.xpipeTerminated(Pipe pipe)
protected void	XSub.xpipeTerminated(Pipe pipe)
protected void	XPub.xreadActivated(Pipe pipe)
protected void	XSub.xreadActivated(Pipe pipe)
protected void	XPub.xwriteActivated(Pipe pipe)
protected void	XSub.xwriteActivated(Pipe pipe)

Uses of Pipe in zmq.socket.radiodish

Fields in zmq.socket.radiodish with type parameters of type Pipe

Modifier and Type	Field	Description
private java.util.Map<java.lang.String,java.util.List<Pipe>>	Radio.subscriptions

Methods in zmq.socket.radiodish with parameters of type Pipe

Modifier and Type	Method	Description
private void	Dish.sendSubscriptions(Pipe pipe)
protected void	Dish.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void	Radio.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Dish.xhiccuped(Pipe pipe)
protected void	Dish.xpipeTerminated(Pipe pipe)
void	Radio.xpipeTerminated(Pipe pipe)
protected void	Dish.xreadActivated(Pipe pipe)
void	Radio.xreadActivated(Pipe pipe)
protected void	Dish.xwriteActivated(Pipe pipe)
void	Radio.xwriteActivated(Pipe pipe)

Uses of Pipe in zmq.socket.reqrep

Fields in zmq.socket.reqrep declared as Pipe

Modifier and Type	Field	Description
private Pipe	Router.currentOut
private Pipe	Router.Outpipe.pipe

Fields in zmq.socket.reqrep with type parameters of type Pipe

Modifier and Type	Field	Description
private java.util.Set<Pipe>	Router.anonymousPipes
private ValueReference<Pipe>	Req.replyPipe

Methods in zmq.socket.reqrep with parameters of type Pipe

Modifier and Type	Method	Description
private boolean	Router.identifyPeer(Pipe pipe, boolean isLocallyInitiated)
protected void	Dealer.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void	Router.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Dealer.xpipeTerminated(Pipe pipe)
protected void	Req.xpipeTerminated(Pipe pipe)
void	Router.xpipeTerminated(Pipe pipe)
protected void	Dealer.xreadActivated(Pipe pipe)
void	Router.xreadActivated(Pipe pipe)
protected void	Dealer.xwriteActivated(Pipe pipe)
void	Router.xwriteActivated(Pipe pipe)

Method parameters in zmq.socket.reqrep with type arguments of type Pipe

Modifier and Type	Method	Description
protected Msg	Dealer.recvpipe(ValueReference<Pipe> pipe)
protected boolean	Dealer.sendpipe(Msg msg, ValueReference<Pipe> pipe)

Constructors in zmq.socket.reqrep with parameters of type Pipe

Constructor	Description
Outpipe(Pipe pipe, boolean active)

Uses of Pipe in zmq.socket.scattergather

Methods in zmq.socket.scattergather with parameters of type Pipe

Modifier and Type	Method	Description
protected void	Gather.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Scatter.xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void	Gather.xpipeTerminated(Pipe pipe)
protected void	Scatter.xpipeTerminated(Pipe pipe)
protected void	Gather.xreadActivated(Pipe pipe)
protected void	Scatter.xwriteActivated(Pipe pipe)