Package | Description |
---|---|
zmq.socket.pubsub |
Modifier and Type | Class and Description |
---|---|
private static class |
XPub.MarkAsMatching |
private static class |
XPub.SendUnsubscription |
Modifier and Type | Field and Description |
---|---|
private static Mtrie.IMtrieHandler |
XPub.markAsMatching |
private static Mtrie.IMtrieHandler |
XPub.sendUnsubscription |
Modifier and Type | Method and Description |
---|---|
void |
Mtrie.match(java.nio.ByteBuffer data,
int size,
Mtrie.IMtrieHandler func,
XPub pub) |
boolean |
Mtrie.rm(Pipe pipe,
Mtrie.IMtrieHandler func,
XPub pub) |
private boolean |
Mtrie.rmHelper(Pipe pipe,
byte[] buff,
int buffsize,
int maxBuffSize,
Mtrie.IMtrieHandler func,
XPub pub) |