Class YPipe<T>

java.lang.Object

zmq.pipe.YPipe<T>

All Implemented Interfaces:

YPipeBase<T>

public class YPipe<T>
extends Object
implements YPipeBase<T>

Constructor Summary

Constructors

Constructor	Description
YPipe(int qsize)

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

YPipe

public YPipe(int qsize)

Method Details

write

public void write(T value,
 boolean incomplete)

Specified by:

write in interface YPipeBase<T>

unwrite

public T unwrite()

Specified by:

unwrite in interface YPipeBase<T>

flush

public boolean flush()

Specified by:

flush in interface YPipeBase<T>

checkRead

public boolean checkRead()

Specified by:

checkRead in interface YPipeBase<T>

read

public T read()

Specified by:

read in interface YPipeBase<T>

probe

public T probe()

Specified by:

probe in interface YPipeBase<T>