[default module]

Package io.reactivex.internal.queue

Class Summary

Modifier and Type	Class and Description
public class	MpscLinkedQueue< the contained value type T> A multi-producer single consumer unbounded queue.
public class	SpscArrayQueue< the element type of the queue E> A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
public class	SpscLinkedArrayQueue< the contained value type T> A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.