Uses of Class
zmq.Pipe

Packages that use Pipe

Package	Description
zmq

Uses of Pipe in zmq

Fields in zmq declared as Pipe

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

Fields in zmq with type parameters of type Pipe

Modifier and Type	Field and Description
private java.util.Set<Pipe>	Router.anonymousPipes
private java.util.Map<java.lang.String,Pipe>	SocketBase.inprocs
private java.util.List<Pipe>	Dist.pipes
private java.util.List<Pipe>	FQ.pipes
private java.util.List<Pipe>	LB.pipes
private java.util.Set<Pipe>	Mtrie.pipes
private java.util.List<Pipe>	SocketBase.pipes
private java.util.Set<Pipe>	SessionBase.terminatingPipes

Methods in zmq with parameters of type Pipe

Modifier and Type	Method and Description
void	Dist.activated(Pipe pipe)
void	FQ.activated(Pipe pipe)
void	LB.activated(Pipe pipe)
boolean	Mtrie.add(byte[] prefix, int start, Pipe pipe)
boolean	Mtrie.add(byte[] prefix, Pipe pipe)
private boolean	Mtrie.addHelper(byte[] prefix, int start, Pipe pipe)
void	Dist.attach(Pipe pipe)
void	FQ.attach(Pipe pipe)
void	LB.attach(Pipe pipe)
void	SessionBase.attachPipe(Pipe pipe)
private void	SocketBase.attachPipe(Pipe pipe)
private void	SocketBase.attachPipe(Pipe pipe, boolean icanhasall)
void	Pipe.IPipeEvents.hiccuped(Pipe pipe)
void	SessionBase.hiccuped(Pipe pipe)
void	SocketBase.hiccuped(Pipe pipe)
private boolean	Router.identifyPeer(Pipe pipe)
void	Mtrie.IMtrieHandler.invoke(Pipe pipe, byte[] data, int size, java.lang.Object arg)
void	Dist.match(Pipe pipe)
static void	Pipe.pipepair(ZObject[] parents, Pipe[] pipes, int[] hwms, boolean[] delays)
void	Pipe.IPipeEvents.pipeTerminated(Pipe pipe)
void	SessionBase.pipeTerminated(Pipe pipe)
void	SocketBase.pipeTerminated(Pipe pipe)
protected void	SocketBase.processBind(Pipe pipe)
protected void	ZObject.processBind(Pipe pipe)
void	Pipe.IPipeEvents.readActivated(Pipe pipe)
void	SessionBase.readActivated(Pipe pipe)
void	SocketBase.readActivated(Pipe pipe)
boolean	Mtrie.rm(byte[] prefix, int start, Pipe pipe)
boolean	Mtrie.rm(Pipe pipe, Mtrie.IMtrieHandler func, java.lang.Object arg, boolean callOnUniq)
private boolean	Mtrie.rmHelper(byte[] prefix, int start, Pipe pipe)
private boolean	Mtrie.rmHelper(Pipe pipe, byte[] buff, int buffsize, int maxBuffSize, Mtrie.IMtrieHandler func, java.lang.Object arg, boolean callOnUniq)
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, java.lang.Object pipe)
protected void	ZObject.sendPipeTerm(Pipe destination)
protected void	ZObject.sendPipeTermAck(Pipe destination)
private void	Pipe.setPeer(Pipe peer)
void	Dist.terminated(Pipe pipe)
void	FQ.terminated(Pipe pipe)
void	LB.terminated(Pipe pipe)
private boolean	Dist.write(Pipe pipe, Msg msg)
void	Pipe.IPipeEvents.writeActivated(Pipe pipe)
void	SessionBase.writeActivated(Pipe pipe)
void	SocketBase.writeActivated(Pipe pipe)
protected void	Dealer.xattachPipe(Pipe pipe, boolean icanhasall)
protected void	Pair.xattachPipe(Pipe pipe, boolean icanhasall)
protected void	Pull.xattachPipe(Pipe pipe, boolean icanhasall)
protected void	Push.xattachPipe(Pipe pipe, boolean icanhasall)
void	Router.xattachPipe(Pipe pipe, boolean icanhasall)
protected abstract void	SocketBase.xattachPipe(Pipe pipe, boolean icanhasall)
protected void	XPub.xattachPipe(Pipe pipe, boolean subscribeToAll)
protected void	XSub.xattachPipe(Pipe pipe, boolean icanhasall)
protected void	SocketBase.xhiccuped(Pipe pipe)
protected void	XSub.xhiccuped(Pipe pipe)
protected void	Dealer.xpipeTerminated(Pipe pipe)
protected void	Pair.xpipeTerminated(Pipe pipe)
protected void	Pull.xpipeTerminated(Pipe pipe)
protected void	Push.xpipeTerminated(Pipe pipe)
void	Router.xpipeTerminated(Pipe pipe)
protected abstract void	SocketBase.xpipeTerminated(Pipe pipe)
protected void	XPub.xpipeTerminated(Pipe pipe)
protected void	XSub.xpipeTerminated(Pipe pipe)
protected void	Dealer.xreadActivated(Pipe pipe)
protected void	Pair.xreadActivated(Pipe pipe)
protected void	Pull.xreadActivated(Pipe pipe)
void	Router.xreadActivated(Pipe pipe)
protected void	SocketBase.xreadActivated(Pipe pipe)
protected void	XPub.xreadActivated(Pipe pipe)
protected void	XSub.xreadActivated(Pipe pipe)
protected void	Dealer.xwriteActivated(Pipe pipe)
protected void	Pair.xwriteActivated(Pipe pipe)
protected void	Push.xwriteActivated(Pipe pipe)
void	Router.xwriteActivated(Pipe pipe)
protected void	SocketBase.xwriteActivated(Pipe pipe)
protected void	XPub.xwriteActivated(Pipe pipe)
protected void	XSub.xwriteActivated(Pipe pipe)

Method parameters in zmq with type arguments of type Pipe

Modifier and Type	Method and Description
Msg	FQ.recvPipe(ValueReference<java.lang.Integer> errno, ValueReference<Pipe> pipe)

Constructors in zmq with parameters of type Pipe

Constructor and Description
Outpipe(Pipe pipe, boolean active)