Package com.clickhouse.client.stream
Class AdaptiveQueue<E>
- java.lang.Object
-
- com.clickhouse.client.stream.AdaptiveQueue<E>
-
public final class AdaptiveQueue<E> extends Object
-
-
Constructor Summary
Constructors Constructor Description AdaptiveQueue(CapacityPolicy policy, E... array)AdaptiveQueue(CapacityPolicy policy, List<E> list)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidadd(E e)voidclear()booleanoffer(E e)Epoll()intsize()
-
-
-
Constructor Detail
-
AdaptiveQueue
public AdaptiveQueue(CapacityPolicy policy, E... array)
-
AdaptiveQueue
public AdaptiveQueue(CapacityPolicy policy, List<E> list)
-
-