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 final Pipe	Ctx.PendingConnection.bindPipe
private final Pipe	Ctx.PendingConnection.connectPipe
private final Pipe	SocketBase.EndpointPipe.pipe

Fields in zmq with type parameters of type Pipe

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

Methods in zmq with parameters of type Pipe

Modifier and Type	Method	Description
private void	SocketBase.addEndpoint(String addr, Own endpoint, Pipe pipe)
private void	SocketBase.attachPipe(Pipe pipe, boolean isLocallyInitiated)
private void	SocketBase.attachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
final void	SocketBase.hiccuped(Pipe pipe)
(package private) void	Ctx.pendConnection(String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
protected final void	ZObject.pendConnection(String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
final void	SocketBase.pipeTerminated(Pipe pipe)
protected final void	SocketBase.processBind(Pipe pipe)
protected void	ZObject.processBind(Pipe pipe)
final void	SocketBase.readActivated(Pipe pipe)
protected final void	ZObject.sendActivateRead(Pipe destination)
protected final void	ZObject.sendActivateWrite(Pipe destination, long msgsRead)
protected final void	ZObject.sendBind(Own destination, Pipe pipe)
protected final void	ZObject.sendBind(Own destination, Pipe pipe, boolean incSeqnum)
protected final void	ZObject.sendHiccup(Pipe destination, YPipeBase<Msg> pipe)
protected final void	ZObject.sendPipeTerm(Pipe destination)
protected final void	ZObject.sendPipeTermAck(Pipe destination)
final 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

Modifier	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 final 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 final List<Pipe>	FQ.pipes
private final 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

Modifier	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

Modifier	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 final Deque<Pipe>	XPub.pendingPipes
private final List<Pipe>	Dist.pipes
private 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) final 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 final Map<String, 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 final Set<Pipe>	Router.anonymousPipes
private final 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 final Msg	Dealer.recvpipe(ValueReference<Pipe> pipe)
protected final boolean	Dealer.sendpipe(Msg msg, ValueReference<Pipe> pipe)

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

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