Package io.reactivex.rxjava3.subjects
Class BehaviorSubject.BehaviorDisposable<T>
- java.lang.Object
-
- io.reactivex.rxjava3.subjects.BehaviorSubject.BehaviorDisposable<T>
-
- All Implemented Interfaces:
Disposable
,Predicate<java.lang.Object>
,AppendOnlyLinkedArrayList.NonThrowingPredicate<java.lang.Object>
- Enclosing class:
- BehaviorSubject<T>
static final class BehaviorSubject.BehaviorDisposable<T> extends java.lang.Object implements Disposable, AppendOnlyLinkedArrayList.NonThrowingPredicate<java.lang.Object>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
cancelled
(package private) Observer<? super T>
downstream
(package private) boolean
emitting
(package private) boolean
fastPath
(package private) long
index
(package private) boolean
next
(package private) AppendOnlyLinkedArrayList<java.lang.Object>
queue
(package private) BehaviorSubject<T>
state
-
Constructor Summary
Constructors Constructor Description BehaviorDisposable(Observer<? super T> actual, BehaviorSubject<T> state)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dispose()
Dispose the resource, the operation should be idempotent.(package private) void
emitFirst()
(package private) void
emitLoop()
(package private) void
emitNext(java.lang.Object value, long stateIndex)
boolean
isDisposed()
Returns true if this resource has been disposed.boolean
test(java.lang.Object o)
Test the given input value and return a boolean.
-
-
-
Field Detail
-
state
final BehaviorSubject<T> state
-
next
boolean next
-
emitting
boolean emitting
-
queue
AppendOnlyLinkedArrayList<java.lang.Object> queue
-
fastPath
boolean fastPath
-
cancelled
volatile boolean cancelled
-
index
long index
-
-
Constructor Detail
-
BehaviorDisposable
BehaviorDisposable(Observer<? super T> actual, BehaviorSubject<T> state)
-
-
Method Detail
-
dispose
public void dispose()
Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
emitFirst
void emitFirst()
-
emitNext
void emitNext(java.lang.Object value, long stateIndex)
-
test
public boolean test(java.lang.Object o)
Description copied from interface:Predicate
Test the given input value and return a boolean.
-
emitLoop
void emitLoop()
-
-