Package | Description |
---|---|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.pipe |
Modifier and Type | Method and Description |
---|---|
protected void |
ZObject.processHiccup(YPipeBase<Msg> hiccupPipe) |
protected void |
ZObject.sendHiccup(Pipe destination,
YPipeBase<Msg> pipe) |
Modifier and Type | Class and Description |
---|---|
class |
YPipe<T> |
class |
YPipeConflate<T extends Msg> |
Modifier and Type | Field and Description |
---|---|
private YPipeBase<Msg> |
Pipe.inpipe |
private YPipeBase<Msg> |
Pipe.outpipe |
Modifier and Type | Method and Description |
---|---|
protected void |
Pipe.processHiccup(YPipeBase<Msg> pipe) |
Constructor and Description |
---|
Pipe(ZObject parent,
YPipeBase<Msg> inpipe,
YPipeBase<Msg> outpipe,
int inhwm,
int outhwm,
boolean conflate) |
Pipe(ZObject parent,
YPipeBase<Msg> inpipe,
YPipeBase<Msg> outpipe,
int inhwm,
int outhwm,
boolean conflate) |