Top Description Methods
io.reactivex.rxjava3.disposables

public Interface Disposable

Known Direct Subinterfaces
io.reactivex.rxjava3.operators.QueueDisposable
Known Direct Implementers
io.reactivex.rxjava3.disposables.FutureDisposable, io.reactivex.rxjava3.disposables.ReferenceDisposable, io.reactivex.rxjava3.disposables.SerialDisposable, io.reactivex.rxjava3.internal.disposables.ArrayCompositeDisposable, io.reactivex.rxjava3.internal.disposables.CancellableDisposable, io.reactivex.rxjava3.internal.disposables.DisposableHelper, io.reactivex.rxjava3.internal.disposables.ListCompositeDisposable, io.reactivex.rxjava3.internal.disposables.SequentialDisposable, io.reactivex.rxjava3.internal.jdk8.CompletableFromCompletionStage.CompletionStageHandler, io.reactivex.rxjava3.internal.jdk8.FlowableCollectWithCollectorSingle.CollectorSingleObserver, io.reactivex.rxjava3.internal.jdk8.MaybeFromCompletionStage.CompletionStageHandler, io.reactivex.rxjava3.internal.jdk8.MaybeMapOptional.MapOptionalMaybeObserver, io.reactivex.rxjava3.internal.jdk8.ObservableCollectWithCollectorSingle.CollectorSingleObserver, io.reactivex.rxjava3.internal.jdk8.ObservableFlatMapStream.FlatMapStreamObserver, io.reactivex.rxjava3.internal.jdk8.SingleFromCompletionStage.CompletionStageHandler, io.reactivex.rxjava3.internal.jdk8.SingleMapOptional.MapOptionalSingleObserver, io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease, io.reactivex.rxjava3.internal.observers.BiConsumerSingleObserver, io.reactivex.rxjava3.internal.observers.BlockingBaseObserver, io.reactivex.rxjava3.internal.observers.BlockingDisposableMultiObserver, io.reactivex.rxjava3.internal.observers.BlockingObserver, io.reactivex.rxjava3.internal.observers.CallbackCompletableObserver, io.reactivex.rxjava3.internal.observers.ConsumerSingleObserver, io.reactivex.rxjava3.internal.observers.DisposableLambdaObserver, io.reactivex.rxjava3.internal.observers.EmptyCompletableObserver, io.reactivex.rxjava3.internal.observers.ForEachWhileObserver, io.reactivex.rxjava3.internal.observers.FutureMultiObserver, io.reactivex.rxjava3.internal.observers.FutureObserver, io.reactivex.rxjava3.internal.observers.InnerQueuedObserver, io.reactivex.rxjava3.internal.observers.LambdaObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableHide.HideCompletableObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableAndThenCompletable.SourceObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableCache.InnerCompletableCache, io.reactivex.rxjava3.internal.operators.completable.CompletableConcat.CompletableConcatSubscriber, io.reactivex.rxjava3.internal.operators.completable.CompletableCreate.Emitter, io.reactivex.rxjava3.internal.operators.completable.CompletableDelay.Delay, io.reactivex.rxjava3.internal.operators.completable.CompletableDetach.DetachCompletableObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableDisposeOn.DisposeOnObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableDoFinally.DoFinallyObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableFromPublisher.FromPublisherSubscriber, io.reactivex.rxjava3.internal.operators.completable.CompletableMerge.CompletableMergeSubscriber, io.reactivex.rxjava3.internal.operators.completable.CompletableMerge.CompletableMergeSubscriber.MergeInnerObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableMergeArray.InnerCompletableObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableMergeArrayDelayError.TryTerminateAndReportDisposable, io.reactivex.rxjava3.internal.operators.completable.CompletableMergeIterable.MergeCompletableObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableObserveOn.ObserveOnCompletableObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableOnErrorReturn.OnErrorReturnMaybeObserver, io.reactivex.rxjava3.internal.operators.completable.CompletablePeek.CompletableObserverImplementation, io.reactivex.rxjava3.internal.operators.completable.CompletableResumeNext.ResumeNextObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableSubscribeOn.SubscribeOnObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableTakeUntilCompletable.TakeUntilMainObserver, io.reactivex.rxjava3.internal.operators.completable.CompletableTimer.TimerDisposable, io.reactivex.rxjava3.internal.operators.completable.CompletableUsing.UsingObserver, io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableIterable.BlockingFlowableIterator, io.reactivex.rxjava3.internal.operators.flowable.FlowableAllSingle.AllSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableAnySingle.AnySubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferBoundary.BufferBoundarySubscriber.BufferOpenSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferBoundary.BufferCloseSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableLastMaybe.LastSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableLastSingle.LastSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableSequenceEqualSingle.EqualCoordinator, io.reactivex.rxjava3.internal.operators.flowable.FlowableSingleMaybe.SingleElementSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableSingleSingle.SingleElementSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableElementAtMaybe.ElementAtSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableElementAtSingle.ElementAtSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMap.InnerSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.InnerConsumer, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.InnerObserver, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapMaybe.FlatMapMaybeSubscriber.InnerObserver, io.reactivex.rxjava3.internal.operators.flowable.FlowableFlatMapSingle.FlatMapSingleSubscriber.InnerObserver, io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferExactBoundary.BufferExactBoundarySubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableDebounceTimed.DebounceEmitter, io.reactivex.rxjava3.internal.operators.flowable.FlowableTimeout.TimeoutConsumer, io.reactivex.rxjava3.internal.operators.flowable.FlowableToListSingle.ToListSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.WindowEndSubscriberIntercept, io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupJoin.LeftRightSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupJoin.LeftRightEndSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableIgnoreElementsCompletable.IgnoreElementsSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowablePublish.PublishConnection, io.reactivex.rxjava3.internal.operators.flowable.FlowableReduceMaybe.ReduceSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableReduceSeedSingle.ReduceSeedObserver, io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.ReplaySubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.InnerSubscription, io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferTimed.BufferExactUnboundedSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferTimed.BufferExactBoundedSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableCollectSingle.CollectSubscriber, io.reactivex.rxjava3.internal.operators.flowable.FlowableCountSingle.CountSubscriber, io.reactivex.rxjava3.internal.operators.maybe.MaybeCache.CacheDisposable, io.reactivex.rxjava3.internal.operators.maybe.MaybeCallbackObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeContains.ContainsMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeCount.CountMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeCreate.Emitter, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelay.DelayMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelayOtherPublisher.DelayMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelaySubscriptionOtherPublisher.OtherSubscriber, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelayWithCompletable.OtherObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDematerialize.DematerializeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDetach.DetachMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoAfterSuccess.DoAfterObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoFinally.DoFinallyObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoOnEvent.DoOnEventMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoOnLifecycle.MaybeLifecycleObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeHide.HideMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeIgnoreElement.IgnoreMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeIgnoreElementCompletable.IgnoreMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeIsEmpty.IsEmptyMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeIsEmptySingle.IsEmptyMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeMap.MapMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeObserveOn.ObserveOnMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorComplete.OnErrorCompleteMultiObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorNext.OnErrorNextMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorReturn.OnErrorReturnMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybePeek.MaybePeekObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeSubscribeOn.SubscribeOnMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeEqualSingle.EqualCoordinator, io.reactivex.rxjava3.internal.operators.maybe.MaybeFilter.FilterMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFilterSingle.FilterMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapBiSelector.FlatMapBiMainObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapCompletable.FlatMapCompletableObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapNotification.FlatMapMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapSingle.FlatMapMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatten.FlatMapMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeFromCompletable.FromCompletableObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTakeUntilMaybe.TakeUntilMainMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTakeUntilPublisher.TakeUntilMainMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeInterval.TimeIntervalMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutMaybe.TimeoutMainMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutPublisher.TimeoutMainMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimer.TimerDisposable, io.reactivex.rxjava3.internal.operators.maybe.MaybeToSingle.ToSingleMaybeSubscriber, io.reactivex.rxjava3.internal.operators.maybe.MaybeUnsubscribeOn.UnsubscribeOnMaybeObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeUsing.UsingObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeZipArray.ZipCoordinator, io.reactivex.rxjava3.internal.operators.maybe.MaybeFromSingle.FromSingleObserver, io.reactivex.rxjava3.internal.operators.maybe.MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver, io.reactivex.rxjava3.internal.operators.mixed.CompletableAndThenObservable.AndThenObservableObserver, io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver, io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapCompletable.ConcatMapCompletableObserver, io.reactivex.rxjava3.internal.operators.mixed.FlowableSwitchMapCompletable.SwitchMapCompletableObserver, io.reactivex.rxjava3.internal.operators.mixed.MaterializeSingleObserver, io.reactivex.rxjava3.internal.operators.mixed.MaybeFlatMapObservable.FlatMapObserver, io.reactivex.rxjava3.internal.operators.mixed.ObservableSwitchMapCompletable.SwitchMapCompletableObserver, io.reactivex.rxjava3.internal.operators.mixed.ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver, io.reactivex.rxjava3.internal.operators.mixed.ObservableSwitchMapSingle.SwitchMapSingleMainObserver, io.reactivex.rxjava3.internal.operators.mixed.SingleFlatMapObservable.FlatMapObserver, io.reactivex.rxjava3.internal.operators.observable.BlockingObservableIterable.BlockingObservableIterator, io.reactivex.rxjava3.internal.operators.observable.ObservableAll.AllObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableAllSingle.AllObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableAmb.AmbCoordinator, io.reactivex.rxjava3.internal.operators.observable.ObservableAny.AnyObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableAnySingle.AnyObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBuffer.BufferExactObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBuffer.BufferSkipObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferBoundary.BufferBoundaryObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferBoundary.BufferBoundaryObserver.BufferOpenObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferBoundary.BufferCloseObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferExactBoundary.BufferExactBoundaryObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableOnErrorComplete.OnErrorCompleteObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableOnErrorReturn.OnErrorReturnObserver, io.reactivex.rxjava3.internal.operators.observable.ObservablePublish.PublishConnection, io.reactivex.rxjava3.internal.operators.observable.ObservablePublish.InnerDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservablePublishSelector.TargetObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableReduceMaybe.ReduceObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableReduceSeedSingle.ReduceSeedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableRefCount.RefCountObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableRepeatWhen.RepeatWhenObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.ReplayObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.InnerDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableRetryWhen.RepeatWhenObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSampleTimed.SampleTimedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSampleWithObservable.SampleMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableScan.ScanObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableScanSeed.ScanSeedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSequenceEqual.EqualCoordinator, io.reactivex.rxjava3.internal.operators.observable.ObservableSequenceEqualSingle.EqualCoordinator, io.reactivex.rxjava3.internal.operators.observable.ObservableSingleMaybe.SingleElementObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSingleSingle.SingleElementObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMap.MergeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapCompletable.FlatMapCompletableMainObserver.InnerObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.InnerObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapMaybe.FlatMapMaybeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapMaybe.FlatMapMaybeObserver.InnerObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapSingle.FlatMapSingleObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlatMapSingle.FlatMapSingleObserver.InnerObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFlattenIterable.FlattenIterableObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableFromPublisher.PublisherSubscriber, io.reactivex.rxjava3.internal.operators.observable.ObservableGenerate.GeneratorDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableSkipLast.SkipLastObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSkipLastTimed.SkipLastTimedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSkipWhile.SkipWhileObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSubscribeOn.SubscribeOnObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableSwitchMap.SwitchMapObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTake.TakeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeLast.TakeLastObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeLastOne.TakeLastOneObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeLastTimed.TakeLastTimedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeUntil.TakeUntilMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeUntilPredicate.TakeUntilPredicateObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTakeWhile.TakeWhileObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableThrottleFirstTimed.DebounceTimedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableThrottleLatest.ThrottleLatestObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeInterval.TimeIntervalObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferTimed.BufferExactUnboundedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferTimed.BufferSkipBoundedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableBufferTimed.BufferExactBoundedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableDebounceTimed.DebounceTimedObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableDebounceTimed.DebounceEmitter, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupBy.GroupByObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupBy.State, io.reactivex.rxjava3.internal.operators.observable.ObservableSkip.SkipObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeout.TimeoutObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeout.TimeoutFallbackObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeout.TimeoutConsumer, io.reactivex.rxjava3.internal.operators.observable.ObservableDelay.DelayObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableDematerialize.DematerializeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableDetach.DetachObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableDoOnEach.DoOnEachObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableElementAt.ElementAtObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableElementAtMaybe.ElementAtObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableElementAtSingle.ElementAtObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.GroupJoinDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.LeftRightObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableGroupJoin.LeftRightEndObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableHide.HideDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableIgnoreElements.IgnoreObservable, io.reactivex.rxjava3.internal.operators.observable.ObservableIgnoreElementsCompletable.IgnoreObservable, io.reactivex.rxjava3.internal.operators.observable.ObservableInterval.IntervalObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableIntervalRange.IntervalRangeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableJoin.JoinDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableLastMaybe.LastObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableLastSingle.LastObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableMapNotification.MapNotificationObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableMaterialize.MaterializeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableMergeWithCompletable.MergeWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableMergeWithMaybe.MergeWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableMergeWithSingle.MergeWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeoutTimed.TimeoutObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimeoutTimed.TimeoutFallbackObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableTimer.TimerObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableToList.ToListObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableToListSingle.ToListObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableUnsubscribeOn.UnsubscribeObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableUsing.UsingObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWindow.WindowExactObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWindow.WindowSkipObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWindowBoundary.WindowBoundaryMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWindowBoundarySelector.WindowBoundaryMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept, io.reactivex.rxjava3.internal.operators.observable.ObservableWindowTimed.AbstractWindowObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWithLatestFrom.WithLatestFromObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableWithLatestFromMany.WithLatestFromObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableZip.ZipCoordinator, io.reactivex.rxjava3.internal.operators.observable.ObservableZipIterable.ZipIterableObserver, io.reactivex.rxjava3.internal.operators.observable.ObserverResourceWrapper, io.reactivex.rxjava3.internal.operators.observable.ObservableCache.CacheDisposable, io.reactivex.rxjava3.internal.operators.observable.ObservableCollect.CollectObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableCollectSingle.CollectObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableCombineLatest.LatestCoordinator, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatMap.SourceObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatMap.ConcatMapDelayErrorObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatMapEager.ConcatMapEagerMainObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatMapScheduler.ConcatMapObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatMapScheduler.ConcatMapDelayErrorObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatWithCompletable.ConcatWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatWithMaybe.ConcatWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableConcatWithSingle.ConcatWithObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableCount.CountObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableCountSingle.CountObserver, io.reactivex.rxjava3.internal.operators.observable.ObservableCreate.CreateEmitter, io.reactivex.rxjava3.internal.operators.observable.ObservableDebounce.DebounceObserver, io.reactivex.rxjava3.internal.operators.single.SingleFlatMap.SingleFlatMapCallback, io.reactivex.rxjava3.internal.operators.single.SingleCache.CacheDisposable, io.reactivex.rxjava3.internal.operators.single.SingleCreate.Emitter, io.reactivex.rxjava3.internal.operators.single.SingleDelayWithCompletable.OtherObserver, io.reactivex.rxjava3.internal.operators.single.SingleDelayWithObservable.OtherSubscriber, io.reactivex.rxjava3.internal.operators.single.SingleDelayWithPublisher.OtherSubscriber, io.reactivex.rxjava3.internal.operators.single.SingleDelayWithSingle.OtherObserver, io.reactivex.rxjava3.internal.operators.single.SingleDematerialize.DematerializeObserver, io.reactivex.rxjava3.internal.operators.single.SingleDetach.DetachSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleDoAfterSuccess.DoAfterObserver, io.reactivex.rxjava3.internal.operators.single.SingleDoAfterTerminate.DoAfterTerminateObserver, io.reactivex.rxjava3.internal.operators.single.SingleDoFinally.DoFinallyObserver, io.reactivex.rxjava3.internal.operators.single.SingleDoOnDispose.DoOnDisposeObserver, io.reactivex.rxjava3.internal.operators.single.SingleDoOnLifecycle.SingleLifecycleObserver, io.reactivex.rxjava3.internal.operators.single.SingleFlatMapBiSelector.FlatMapBiMainObserver, io.reactivex.rxjava3.internal.operators.single.SingleFlatMapCompletable.FlatMapCompletableObserver, io.reactivex.rxjava3.internal.operators.single.SingleFlatMapMaybe.FlatMapSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleFlatMapNotification.FlatMapSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleFromPublisher.ToSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleHide.HideSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleObserveOn.ObserveOnSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleResumeNext.ResumeMainSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleSubscribeOn.SubscribeOnObserver, io.reactivex.rxjava3.internal.operators.single.SingleTakeUntil.TakeUntilMainObserver, io.reactivex.rxjava3.internal.operators.single.SingleTimeInterval.TimeIntervalSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleTimeout.TimeoutMainObserver, io.reactivex.rxjava3.internal.operators.single.SingleTimer.TimerDisposable, io.reactivex.rxjava3.internal.operators.single.SingleUnsubscribeOn.UnsubscribeOnSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleUsing.UsingSingleObserver, io.reactivex.rxjava3.internal.operators.single.SingleZipArray.ZipCoordinator, io.reactivex.rxjava3.internal.schedulers.AbstractDirectTask, io.reactivex.rxjava3.internal.schedulers.ExecutorScheduler.ExecutorWorker.BooleanRunnable, io.reactivex.rxjava3.internal.schedulers.ExecutorScheduler.ExecutorWorker.InterruptibleRunnable, io.reactivex.rxjava3.internal.schedulers.ExecutorScheduler.DelayedRunnable, io.reactivex.rxjava3.internal.schedulers.InstantPeriodicTask, io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable, io.reactivex.rxjava3.internal.schedulers.SchedulerWhen, io.reactivex.rxjava3.internal.schedulers.SchedulerWhen.ScheduledAction, io.reactivex.rxjava3.internal.schedulers.SchedulerWhen.SubscribedDisposable, io.reactivex.rxjava3.internal.subscribers.BoundedSubscriber, io.reactivex.rxjava3.internal.subscribers.DisposableAutoReleaseSubscriber, io.reactivex.rxjava3.internal.subscribers.ForEachWhileSubscriber, io.reactivex.rxjava3.internal.subscribers.LambdaSubscriber, io.reactivex.rxjava3.internal.subscribers.SubscriberResourceWrapper, io.reactivex.rxjava3.internal.subscriptions.ArrayCompositeSubscription, io.reactivex.rxjava3.internal.subscriptions.AsyncSubscription, io.reactivex.rxjava3.internal.util.EmptyComponent, io.reactivex.rxjava3.observers.DisposableCompletableObserver, io.reactivex.rxjava3.observers.DisposableMaybeObserver, io.reactivex.rxjava3.observers.DisposableObserver, io.reactivex.rxjava3.observers.DisposableSingleObserver, io.reactivex.rxjava3.observers.ResourceCompletableObserver, io.reactivex.rxjava3.observers.ResourceMaybeObserver, io.reactivex.rxjava3.observers.ResourceObserver, io.reactivex.rxjava3.observers.ResourceSingleObserver, io.reactivex.rxjava3.observers.SafeObserver, io.reactivex.rxjava3.observers.SerializedObserver, io.reactivex.rxjava3.observers.TestObserver, io.reactivex.rxjava3.schedulers.TestScheduler.TestWorker.QueueRemove, io.reactivex.rxjava3.subjects.BehaviorSubject.BehaviorDisposable, io.reactivex.rxjava3.subjects.CompletableSubject.CompletableDisposable, io.reactivex.rxjava3.subjects.MaybeSubject.MaybeDisposable, io.reactivex.rxjava3.subjects.PublishSubject.PublishDisposable, io.reactivex.rxjava3.subjects.ReplaySubject.ReplayDisposable, io.reactivex.rxjava3.subjects.SingleSubject.SingleDisposable, io.reactivex.rxjava3.subscribers.DisposableSubscriber, io.reactivex.rxjava3.subscribers.ResourceSubscriber, io.reactivex.rxjava3.core.Scheduler.Worker, io.reactivex.rxjava3.core.Scheduler.PeriodicDirectTask, io.reactivex.rxjava3.core.Scheduler.DisposeTask, io.reactivex.rxjava3.disposables.CompositeDisposable
Imports
io.reactivex.rxjava3.annotations.NonNull, io.reactivex.rxjava3.functions.Action, io.reactivex.rxjava3.internal.disposables.EmptyDisposable, io.reactivex.rxjava3.internal.functions.Functions, org.reactivestreams.Subscription, java.util.Objects, java.util.concurrent.Future

Represents a disposable resource.

Method Summary

Modifier and TypeMethod and Description
public void
dispose()

Dispose the resource, the operation should be idempotent.

public static @NonNull Disposable

Returns:

a shared, disposed Disposable instance
disposed
()

Returns a shared, disposed Disposable instance.

public static @NonNull Disposable

Returns:

a new, non-disposed Disposable instance
empty
()

Returns a new, non-disposed Disposable instance.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromAction
(@NonNull Action
the Action to wrap
action
)

Construct a Disposable by wrapping a Action that is executed exactly once when the Disposable is disposed.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromAutoCloseable
(@NonNull AutoCloseable
the AutoCloseable to wrap
autoCloseable
)

Construct a Disposable by wrapping an AutoCloseable that is closed exactly once when the Disposable is disposed.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromFuture
(@NonNull Future<?>
the Future to wrap
future
)

Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromFuture
(@NonNull Future<?>
the Future to wrap
future
,
boolean
if true, the future cancel happens via Future.cancel(true)
allowInterrupt
)

Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromRunnable
(@NonNull Runnable
the Runnable to wrap
run
)

Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.

public static @NonNull Disposable

Returns:

the new Disposable instance
fromSubscription
(@NonNull Subscription
the Runnable to wrap
subscription
)

Construct a Disposable by wrapping a Subscription that is cancelled exactly once when the Disposable is disposed.

public boolean

Returns:

true if this resource has been disposed
isDisposed
()

Returns true if this resource has been disposed.

public static @NonNull AutoCloseable

Returns:

the new AutoCloseable instance
toAutoCloseable
(@NonNull Disposable
the Disposable instance
disposable
)

Construct an AutoCloseable by wrapping a Disposable that is disposed when the returned AutoCloseable is closed.

Method Detail

disposeback to summary
public void dispose()

Dispose the resource, the operation should be idempotent.

disposedback to summary
public static @NonNull Disposable disposed()

Returns a shared, disposed Disposable instance.

Returns:@NonNull Disposable

a shared, disposed Disposable instance

Annotations
@NonNull
Since
3.0.0
emptyback to summary
public static @NonNull Disposable empty()

Returns a new, non-disposed Disposable instance.

Returns:@NonNull Disposable

a new, non-disposed Disposable instance

Annotations
@NonNull
Since
3.0.0
fromActionback to summary
public static @NonNull Disposable fromAction(@NonNull Action action)

Construct a Disposable by wrapping a Action that is executed exactly once when the Disposable is disposed.

Parameters
action:@NonNull Action

the Action to wrap

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if action is null
Since
3.0.0
fromAutoCloseableback to summary
public static @NonNull Disposable fromAutoCloseable(@NonNull AutoCloseable autoCloseable)

Construct a Disposable by wrapping an AutoCloseable that is closed exactly once when the Disposable is disposed.

Parameters
autoCloseable:@NonNull AutoCloseable

the AutoCloseable to wrap

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if autoCloseable is null
Since
3.0.0
fromFutureback to summary
public static @NonNull Disposable fromFuture(@NonNull Future<?> future)

Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.

The Future is cancelled with mayInterruptIfRunning == true.

Parameters
future:@NonNull Future<?>

the Future to wrap

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if future is null
Since
3.0.0
See Also
fromFuture(Future, boolean)
fromFutureback to summary
public static @NonNull Disposable fromFuture(@NonNull Future<?> future, boolean allowInterrupt)

Construct a Disposable by wrapping a Future that is cancelled exactly once when the Disposable is disposed.

Parameters
future:@NonNull Future<?>

the Future to wrap

allowInterrupt:boolean

if true, the future cancel happens via Future.cancel(true)

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if future is null
Since
3.0.0
fromRunnableback to summary
public static @NonNull Disposable fromRunnable(@NonNull Runnable run)

Construct a Disposable by wrapping a Runnable that is executed exactly once when the Disposable is disposed.

Parameters
run:@NonNull Runnable

the Runnable to wrap

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if run is null
Since
3.0.0
fromSubscriptionback to summary
public static @NonNull Disposable fromSubscription(@NonNull Subscription subscription)

Construct a Disposable by wrapping a Subscription that is cancelled exactly once when the Disposable is disposed.

Parameters
subscription:@NonNull Subscription

the Runnable to wrap

Returns:@NonNull Disposable

the new Disposable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if subscription is null
Since
3.0.0
isDisposedback to summary
public boolean isDisposed()

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

toAutoCloseableback to summary
public static @NonNull AutoCloseable toAutoCloseable(@NonNull Disposable disposable)

Construct an AutoCloseable by wrapping a Disposable that is disposed when the returned AutoCloseable is closed.

Parameters
disposable:@NonNull Disposable

the Disposable instance

Returns:@NonNull AutoCloseable

the new AutoCloseable instance

Annotations
@NonNull
Exceptions
NullPointerException:
if disposable is null
Since
3.0.0