Class UnbufferedPushStreamImpl<T,​U extends java.util.concurrent.BlockingQueue<PushEvent<? extends T>>>