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

All Implemented Interfaces:
AutoCloseable, PushStream<T>

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