Top Constructors Methods
io.rsocket.internal.jctools.queues

pack-priv final Class MessagePassingQueueUtil

extends Object
Class Inheritance
Imports
io.rsocket.internal.jctools.queues.MessagePassingQueue.Consumer, .MessagePassingQueue.ExitCondition, .MessagePassingQueue.Supplier, .MessagePassingQueue.WaitStrategy

Constructor Summary

AccessConstructor and Description
pack-priv
MessagePassingQueueUtil()

Method Summary

Modifier and TypeMethod and Description
public static <E> int
drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, int limit)

public static <E> int
drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c)

public static <E> void
drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)

public static <E> void
fill(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)

public static <E> int
fillBounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)

public static <E> int
fillInBatchesToLimit(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, int batch, int limit)

public static <E> int
fillUnbounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Constructor Detail

MessagePassingQueueUtilback to summary
pack-priv MessagePassingQueueUtil()

Method Detail

drainback to summary
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, int limit)
drainback to summary
public static <E> int drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c)
drainback to summary
public static <E> void drain(MessagePassingQueue<E> queue, MessagePassingQueue.Consumer<E> c, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
fillback to summary
public static <E> void fill(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, MessagePassingQueue.WaitStrategy wait, MessagePassingQueue.ExitCondition exit)
fillBoundedback to summary
public static <E> int fillBounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)
fillInBatchesToLimitback to summary
public static <E> int fillInBatchesToLimit(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s, int batch, int limit)
fillUnboundedback to summary
public static <E> int fillUnbounded(MessagePassingQueue<E> q, MessagePassingQueue.Supplier<E> s)