Uses of Class
zmq.pipe.Pipe
Packages that use Pipe
Package
Description
Provides low-level bindings for ØMQ.
-
Uses of Pipe in zmq
Modifier and TypeFieldDescriptionprivate final Pipe
Ctx.PendingConnection.bindPipe
private final Pipe
Ctx.PendingConnection.connectPipe
private final Pipe
SocketBase.EndpointPipe.pipe
Modifier and TypeMethodDescriptionprivate 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
(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
protected final void
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
protected abstract void
SocketBase.xpipeTerminated
(Pipe pipe) protected void
SocketBase.xreadActivated
(Pipe pipe) protected void
SocketBase.xwriteActivated
(Pipe pipe) ModifierConstructorDescriptionEndpointPipe
(Own endpoint, Pipe pipe) PendingConnection
(Ctx.Endpoint endpoint, Pipe connectPipe, Pipe bindPipe) -
Uses of Pipe in zmq.io
Modifier and TypeMethodDescriptionvoid
SessionBase.attachPipe
(Pipe pipe) void
void
SessionBase.pipeTerminated
(Pipe pipe) void
SessionBase.readActivated
(Pipe pipe) void
SessionBase.writeActivated
(Pipe pipe) -
Uses of Pipe in zmq.pipe
Modifier and TypeMethodDescriptionvoid
void
Pipe.IPipeEvents.pipeTerminated
(Pipe pipe) void
Pipe.IPipeEvents.readActivated
(Pipe pipe) private void
void
Pipe.IPipeEvents.writeActivated
(Pipe pipe) -
Uses of Pipe in zmq.socket
Fields in zmq.socket declared as PipeModifier and TypeFieldDescriptionprivate Pipe
Stream.currentOut
private Pipe
FQ.lastIn
private Pipe
Pair.lastIn
private Pipe
Pair.pipe
private Pipe
Stream.Outpipe.pipe
Fields in zmq.socket with type parameters of type PipeMethods in zmq.socket with parameters of type PipeModifier and TypeMethodDescriptionvoid
void
void
void
private void
Stream.identifyPeer
(Pipe pipe, boolean isLocallyInitiated) void
FQ.terminated
(Pipe pipe) void
LB.terminated
(Pipe pipe) protected void
Pair.xattachPipe
(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated) protected void
Stream.xattachPipe
(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated) protected void
Pair.xpipeTerminated
(Pipe pipe) protected void
Stream.xpipeTerminated
(Pipe pipe) protected void
Pair.xreadActivated
(Pipe pipe) protected void
Stream.xreadActivated
(Pipe pipe) protected void
Pair.xwriteActivated
(Pipe pipe) protected void
Stream.xwriteActivated
(Pipe pipe) Method parameters in zmq.socket with type arguments of type PipeModifier and TypeMethodDescriptionFQ.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 -
Uses of Pipe in zmq.socket.pipeline
Methods in zmq.socket.pipeline with parameters of type PipeModifier and TypeMethodDescriptionprotected 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 PipeFields in zmq.socket.pubsub with type parameters of type PipeMethods in zmq.socket.pubsub with parameters of type PipeModifier and TypeMethodDescriptionvoid
boolean
void
void
private boolean
(package private) final boolean
void
Trie.apply
(Trie.ITrieHandler func, Pipe arg) private void
Trie.applyHelper
(byte[] buff, int buffsize, int maxBuffsize, Trie.ITrieHandler func, Pipe pipe) void
void
void
void
private void
XPub.markAsMatching
(Pipe pipe) void
boolean
boolean
Mtrie.rm
(Pipe pipe, Mtrie.IMtrieHandler func, XPub pub) private boolean
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
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
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.reqrep
Fields in zmq.socket.reqrep declared as PipeFields in zmq.socket.reqrep with type parameters of type PipeModifier and TypeFieldDescriptionRouter.anonymousPipes
private final ValueReference
<Pipe> Req.replyPipe
Methods in zmq.socket.reqrep with parameters of type PipeModifier and TypeMethodDescriptionprivate 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 PipeModifier and TypeMethodDescriptionprotected 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