Package | Description |
---|---|
org.zeromq.timer |
Provides timing utility classes for ØMQ.
|
zmq.io | |
zmq.util |
Modifier and Type | Field and Description |
---|---|
private Supplier<java.lang.Long> |
ZTicket.clock |
Constructor and Description |
---|
ZTicker(Supplier<java.lang.Long> clock) |
ZTicket(Supplier<java.lang.Long> clock) |
ZTicket(Supplier<java.lang.Long> clock,
java.util.List<ZTicket.Ticket> tickets) |
ZTimer(Supplier<java.lang.Long> clock) |
Modifier and Type | Class and Description |
---|---|
private class |
StreamEngine.ProducePongMessage |
Modifier and Type | Field and Description |
---|---|
private Supplier<Msg> |
StreamEngine.nextHandshakeCommand |
private Supplier<Msg> |
StreamEngine.nextIdentity |
private Supplier<Msg> |
StreamEngine.nextMsg |
private Supplier<Msg> |
StreamEngine.producePingMessage |
private Supplier<Msg> |
StreamEngine.pullAndEncode |
private Supplier<Msg> |
StreamEngine.pullMsgFromSession |
Modifier and Type | Field and Description |
---|---|
private Supplier<java.lang.Long> |
Timers.clock |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.checkArgument(boolean expression,
Supplier<java.lang.String> errorMessage) |
Constructor and Description |
---|
Timers(Supplier<java.lang.Long> clock)
Builds a new timer.
|