zmq.pipe

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 and Description
YPipeConflate()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

YPipeConflate

public YPipeConflate()

Method Detail

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>