Class YPipeConflate<T extends Msg>

java.lang.Object

zmq.pipe.YPipeConflate<T>

All Implemented Interfaces:

YPipeBase<T>

public class YPipeConflate<T extends Msg>
extends Object
implements YPipeBase<T>

Constructor Summary

Constructors

Constructor	Description
YPipeConflate()

Method Summary

Modifier and Type	Method	Description
boolean	checkRead()
boolean	flush()
T	probe()
T	read()
T	unwrite()
void	write(T value, boolean incomplete)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

YPipeConflate

public YPipeConflate()

Method Details

write

public void write(T value,
 boolean incomplete)

Specified by:

write in interface YPipeBase<T extends Msg>

unwrite

public T unwrite()

Specified by:

unwrite in interface YPipeBase<T extends Msg>

flush

public boolean flush()

Specified by:

flush in interface YPipeBase<T extends Msg>

checkRead

public boolean checkRead()

Specified by:

checkRead in interface YPipeBase<T extends Msg>

read

public T read()

Specified by:

read in interface YPipeBase<T extends Msg>

probe

public T probe()

Specified by:

probe in interface YPipeBase<T extends Msg>