Package zmq.socket
Class Stream
java.lang.Object
zmq.ZObject
zmq.Own
zmq.SocketBase
zmq.socket.Stream
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Pipe
private final FQ
private boolean
private boolean
private int
private Map<Blob,
Stream.Outpipe> private boolean
private Msg
private Msg
Fields inherited from class zmq.SocketBase
connectRid
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
identifyPeer
(Pipe pipe, boolean isLocallyInitiated) protected void
xattachPipe
(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated) protected boolean
xhasIn()
protected boolean
xhasOut()
protected void
xpipeTerminated
(Pipe pipe) protected void
xreadActivated
(Pipe pipe) xrecv()
protected boolean
protected boolean
xsetsockopt
(int option, Object optval) protected void
xwriteActivated
(Pipe pipe) Methods inherited from class zmq.SocketBase
bind, close, connect, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshaken, eventListening, getCredential, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, monitor, monitorEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xhiccuped
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface zmq.poll.IPollEvents
acceptEvent, connectEvent, outEvent, timerEvent
-
Field Details
-
fq
-
prefetched
private boolean prefetched -
identitySent
private boolean identitySent -
prefetchedId
-
prefetchedMsg
-
outpipes
-
currentOut
-
moreOut
private boolean moreOut -
nextRid
private int nextRid
-
-
Constructor Details
-
Stream
-
-
Method Details
-
xattachPipe
- Specified by:
xattachPipe
in classSocketBase
-
xpipeTerminated
- Specified by:
xpipeTerminated
in classSocketBase
-
xreadActivated
- Overrides:
xreadActivated
in classSocketBase
-
xwriteActivated
- Overrides:
xwriteActivated
in classSocketBase
-
xsend
- Overrides:
xsend
in classSocketBase
-
xsetsockopt
- Overrides:
xsetsockopt
in classSocketBase
-
xrecv
- Overrides:
xrecv
in classSocketBase
-
xhasIn
protected boolean xhasIn()- Overrides:
xhasIn
in classSocketBase
-
xhasOut
protected boolean xhasOut()- Overrides:
xhasOut
in classSocketBase
-
identifyPeer
-