Modifier and Type	Class and Description
pack-priv static class	ObservableCreate.CreateEmitter<T>
pack-priv static class	ObservableCreate.SerializedEmitter< the value type T> Serializes calls to onNext, onError and onComplete.

Modifier and Type	Field and Description
pack-priv final ObservableOnSubscribe<T>	source

Access	Constructor and Description
public	ObservableCreate(ObservableOnSubscribe<T> source)

Modifier and Type	Method and Description
protected void	subscribeActual(Observer<? super T> observer)

source	back to summary
pack-priv final ObservableOnSubscribe<T> source

ObservableCreate	back to summary
public ObservableCreate(ObservableOnSubscribe<T> source)

subscribeActual	back to summary
protected void subscribeActual(Observer<? super T> observer) Annotations @Override

io.reactivex.rxjava3.internal.operators.observable back to summary

pack-priv final Class ObservableCreate.CreateEmitter<T>

Class Inheritance

extends AtomicReference<Disposable>
implements ObservableEmitter<T>, Disposable

java.lang.Object
java.util.concurrent.atomic.AtomicReference
io.reactivex.rxjava3.internal.operators.observable.ObservableCreate.CreateEmitter

All Implemented Interfaces

io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.core.ObservableEmitter, io.reactivex.rxjava3.core.Emitter

Field Summary

Modifier and Type	Field and Description
pack-priv final Observer<? super T>	observer
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	CreateEmitter(Observer<? super T> observer)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed, io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if the downstream disposed the sequence or the emitter was terminated via `onError(Throwable)`, `onComplete` or a successful `tryOnError(Throwable)`.
public void	onComplete() Implements io.reactivex.rxjava3.core.Emitter.onComplete. Signal a completion.
public void	onError(Throwable t)
public void	onNext(T the value to signal, not `null` t) Implements io.reactivex.rxjava3.core.Emitter.onNext. Signal a normal value.
public ObservableEmitter<T>	serialize() Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize. Ensures that calls to `onNext`, `onError` and `onComplete` are properly serialized.
public void	setCancellable(Cancellable c)
public void	setDisposable(Disposable d)
public String	toString() Overrides java.util.concurrent.atomic.AtomicReference.toString. Returns the String representation of the current value.
public boolean	tryOnError(Throwable t)

Field Detail

observer	back to summary
pack-priv final Observer<? super T> observer

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

CreateEmitter	back to summary
pack-priv CreateEmitter(Observer<? super T> observer)

Method Detail

dispose	back to summary
public void dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed back to summary

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed, io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.core.ObservableEmitter.isDisposed. Returns true if the downstream disposed the sequence or the emitter was terminated via `onError(Throwable)`, `onComplete` or a successful `tryOnError(Throwable)`. This method is thread-safe. Returns:boolean true if the downstream disposed the sequence or the emitter was terminated Annotations @Override

public boolean isDisposed()

Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed, io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.core.ObservableEmitter.isDisposed.

Returns true if the downstream disposed the sequence or the emitter was terminated via onError(Throwable), onComplete or a successful tryOnError(Throwable).

This method is thread-safe.

Returns:boolean

true if the downstream disposed the sequence or the emitter was terminated

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements io.reactivex.rxjava3.core.Emitter.onComplete. Doc from io.reactivex.rxjava3.core.Emitter.onComplete. Signal a completion. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements io.reactivex.rxjava3.core.Emitter.onComplete.

Doc from io.reactivex.rxjava3.core.Emitter.onComplete.

Signal a completion.

Annotations

@Override

onError	back to summary
public void onError(Throwable t) Annotations @Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements io.reactivex.rxjava3.core.Emitter.onNext. Doc from io.reactivex.rxjava3.core.Emitter.onNext. Signal a normal value. Parameters t:T the value to signal, not `null` Annotations @Override

public void onNext(T t)

Implements io.reactivex.rxjava3.core.Emitter.onNext.

Doc from io.reactivex.rxjava3.core.Emitter.onNext.

Signal a normal value.

Parameters

t:T: the value to signal, not null

Annotations

@Override

serialize back to summary

serialize	back to summary
public ObservableEmitter<T> serialize() Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize. Doc from io.reactivex.rxjava3.core.ObservableEmitter.serialize. Ensures that calls to `onNext`, `onError` and `onComplete` are properly serialized. Returns:ObservableEmitter<T> the serialized `ObservableEmitter` Annotations @Override

public ObservableEmitter<T> serialize()

Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize.

Doc from io.reactivex.rxjava3.core.ObservableEmitter.serialize.

Ensures that calls to onNext, onError and onComplete are properly serialized.

Returns:ObservableEmitter<T>

the serialized ObservableEmitter

Annotations

@Override

setCancellable	back to summary
public void setCancellable(Cancellable c) Annotations @Override

setDisposable	back to summary
public void setDisposable(Disposable d) Annotations @Override

toString	back to summary
public String toString() Overrides java.util.concurrent.atomic.AtomicReference.toString. Doc from java.util.concurrent.atomic.AtomicReference.toString. Returns the String representation of the current value. Returns:String the String representation of the current value Annotations @Override

toString

back to summary

public String toString()

Overrides java.util.concurrent.atomic.AtomicReference.toString.

Doc from java.util.concurrent.atomic.AtomicReference.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations

@Override

tryOnError	back to summary
public boolean tryOnError(Throwable t) Annotations @Override

io.reactivex.rxjava3.internal.operators.observable back to summary

pack-priv final Class ObservableCreate.SerializedEmitter<T>

Class Inheritance

extends AtomicInteger
implements ObservableEmitter<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.observable.ObservableCreate.SerializedEmitter

All Implemented Interfaces

io.reactivex.rxjava3.core.ObservableEmitter, io.reactivex.rxjava3.core.Emitter

Type Parameters

<T>: the value type

Serializes calls to onNext, onError and onComplete.

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	done
pack-priv final ObservableEmitter<T>	emitter
pack-priv final AtomicThrowable	errors
pack-priv final SpscLinkedArrayQueue<T>	queue
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	SerializedEmitter(ObservableEmitter<T> emitter)

Method Summary

Modifier and Type	Method and Description
pack-priv void	drain()
pack-priv void	drainLoop()
public boolean	isDisposed() Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed. Returns true if the downstream disposed the sequence or the emitter was terminated via `onError(Throwable)`, `onComplete` or a successful `tryOnError(Throwable)`.
public void	onComplete() Implements io.reactivex.rxjava3.core.Emitter.onComplete. Signal a completion.
public void	onError(Throwable t)
public void	onNext(T the value to signal, not `null` t) Implements io.reactivex.rxjava3.core.Emitter.onNext. Signal a normal value.
public ObservableEmitter<T>	serialize() Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize. Ensures that calls to `onNext`, `onError` and `onComplete` are properly serialized.
public void	setCancellable(Cancellable c)
public void	setDisposable(Disposable d)
public String	toString() Overrides java.util.concurrent.atomic.AtomicInteger.toString. Returns the String representation of the current value.
public boolean	tryOnError(Throwable t)

Field Detail

done	back to summary
pack-priv volatile boolean done

emitter	back to summary
pack-priv final ObservableEmitter<T> emitter

errors	back to summary
pack-priv final AtomicThrowable errors

queue	back to summary
pack-priv final SpscLinkedArrayQueue<T> queue

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

Constructor Detail

SerializedEmitter	back to summary
pack-priv SerializedEmitter(ObservableEmitter<T> emitter)

Method Detail

drain	back to summary
pack-priv void drain()

drainLoop	back to summary
pack-priv void drainLoop()

isDisposed back to summary

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed. Doc from io.reactivex.rxjava3.core.ObservableEmitter.isDisposed. Returns true if the downstream disposed the sequence or the emitter was terminated via `onError(Throwable)`, `onComplete` or a successful `tryOnError(Throwable)`. This method is thread-safe. Returns:boolean true if the downstream disposed the sequence or the emitter was terminated Annotations @Override

public boolean isDisposed()

Implements io.reactivex.rxjava3.core.ObservableEmitter.isDisposed.

Doc from io.reactivex.rxjava3.core.ObservableEmitter.isDisposed.

Returns true if the downstream disposed the sequence or the emitter was terminated via onError(Throwable), onComplete or a successful tryOnError(Throwable).

This method is thread-safe.

Returns:boolean

true if the downstream disposed the sequence or the emitter was terminated

Annotations

@Override

onComplete	back to summary
public void onComplete() Implements io.reactivex.rxjava3.core.Emitter.onComplete. Doc from io.reactivex.rxjava3.core.Emitter.onComplete. Signal a completion. Annotations @Override

onComplete

back to summary

public void onComplete()

Implements io.reactivex.rxjava3.core.Emitter.onComplete.

Doc from io.reactivex.rxjava3.core.Emitter.onComplete.

Signal a completion.

Annotations

@Override

onError	back to summary
public void onError(Throwable t) Annotations @Override

onNext back to summary

onNext	back to summary
public void onNext(T t) Implements io.reactivex.rxjava3.core.Emitter.onNext. Doc from io.reactivex.rxjava3.core.Emitter.onNext. Signal a normal value. Parameters t:T the value to signal, not `null` Annotations @Override

public void onNext(T t)

Implements io.reactivex.rxjava3.core.Emitter.onNext.

Doc from io.reactivex.rxjava3.core.Emitter.onNext.

Signal a normal value.

Parameters

t:T: the value to signal, not null

Annotations

@Override

serialize back to summary

serialize	back to summary
public ObservableEmitter<T> serialize() Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize. Doc from io.reactivex.rxjava3.core.ObservableEmitter.serialize. Ensures that calls to `onNext`, `onError` and `onComplete` are properly serialized. Returns:ObservableEmitter<T> the serialized `ObservableEmitter` Annotations @Override

public ObservableEmitter<T> serialize()

Implements io.reactivex.rxjava3.core.ObservableEmitter.serialize.

Doc from io.reactivex.rxjava3.core.ObservableEmitter.serialize.

Ensures that calls to onNext, onError and onComplete are properly serialized.

Returns:ObservableEmitter<T>

the serialized ObservableEmitter

Annotations

@Override

setCancellable	back to summary
public void setCancellable(Cancellable c) Annotations @Override

setDisposable	back to summary
public void setDisposable(Disposable d) Annotations @Override

toString	back to summary
public String toString() Overrides java.util.concurrent.atomic.AtomicInteger.toString. Doc from java.util.concurrent.atomic.AtomicInteger.toString. Returns the String representation of the current value. Returns:String the String representation of the current value Annotations @Override

toString

back to summary

public String toString()

Overrides java.util.concurrent.atomic.AtomicInteger.toString.

Doc from java.util.concurrent.atomic.AtomicInteger.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations

@Override

tryOnError	back to summary
public boolean tryOnError(Throwable t) Annotations @Override

public final Class ObservableCreate<T>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableCreate.CreateEmitter<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ObservableCreate.SerializedEmitter<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail