Top Fields Constructors Methods
reactor.core.publisher

pack-priv abstract Class FlatMapTracker<T>

Located in compilation unit of reactor.core.publisher.FluxFlatMap.

extends Object
Class Inheritance
Known Direct Subclasses
reactor.core.publisher.FluxFlatMap.FlatMapMain

Field Summary

Modifier and TypeField and Description
pack-priv volatile T[]
array

pack-priv long
consumerIndex

pack-priv int[]
free

pack-priv static final int[]
FREE_EMPTY

pack-priv long
producerIndex

pack-priv volatile int
size

pack-priv static final AtomicIntegerFieldUpdater<FlatMapTracker<T>>
SIZE

Constructor Summary

AccessConstructor and Description
pack-priv
FlatMapTracker()

Method Summary

Modifier and TypeMethod and Description
pack-priv final boolean
add(T entry)

pack-priv abstract T[]
empty()

pack-priv final T[]
get()

pack-priv final boolean
isEmpty()

pack-priv abstract T[]
newArray(int size)

pack-priv void
offerFree(int index)

pack-priv int
pollFree()

pack-priv final void
remove(int index)

pack-priv abstract void
setIndex(T entry, int index)

pack-priv abstract T[]
terminated()

pack-priv final void
unsubscribe()

pack-priv abstract void
unsubscribeEntry(T entry)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

arrayback to summary
pack-priv volatile T[] array
consumerIndexback to summary
pack-priv long consumerIndex
freeback to summary
pack-priv int[] free
FREE_EMPTYback to summary
pack-priv static final int[] FREE_EMPTY
producerIndexback to summary
pack-priv long producerIndex
sizeback to summary
pack-priv volatile int size
SIZEback to summary
pack-priv static final AtomicIntegerFieldUpdater<FlatMapTracker<T>> SIZE
Annotations
@SuppressWarnings:rawtypes

Constructor Detail

FlatMapTrackerback to summary
pack-priv FlatMapTracker()

Method Detail

addback to summary
pack-priv final boolean add(T entry)
emptyback to summary
pack-priv abstract T[] empty()
getback to summary
pack-priv final T[] get()
isEmptyback to summary
pack-priv final boolean isEmpty()
newArrayback to summary
pack-priv abstract T[] newArray(int size)
offerFreeback to summary
pack-priv void offerFree(int index)
pollFreeback to summary
pack-priv int pollFree()
removeback to summary
pack-priv final void remove(int index)
setIndexback to summary
pack-priv abstract void setIndex(T entry, int index)
terminatedback to summary
pack-priv abstract T[] terminated()
unsubscribeback to summary
pack-priv final void unsubscribe()
unsubscribeEntryback to summary
pack-priv abstract void unsubscribeEntry(T entry)