Class UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>>

java.lang.Object
org.osgi.util.pushstream.AbstractPushStreamImpl<T>
org.osgi.util.pushstream.UnbufferedPushStreamImpl<T,U>
All Implemented Interfaces:
AutoCloseable, PushStream<T>
Direct Known Subclasses:
BufferedPushStreamImpl

class UnbufferedPushStreamImpl<T,U extends BlockingQueue<PushEvent<? extends T>>> extends AbstractPushStreamImpl<T> implements PushStream<T>