Top Deprecated
rxjava 1.3.8

Deprecated API


No API in this release is deprecated for removal.

Deprecated Item Summary

SinceDeprecated Item and Description

Returns:

an OnCompleted variety of Notification
rx.Notification.createOnCompleted
(Class<T>
the type token to help with type inference of <T>
type
)

this method does the same as createOnCompleted() and does not use the passed in type hence it's useless.

Returns:

the new Observable instance with the specific behavior.
rx.Observable.cache
(int
the capacity to start with
initialCapacity
)

Use cacheWithInitialCapacity(int) instead.

Returns:

the new Observable instance
rx.Observable.create
(Observable.OnSubscribe<T>
the callback to execute for each individual Subscriber that subscribes to the returned Observable
f
)

1.2.7 - inherently unsafe, use the other create() methods for basic cases or see unsafeCreate(OnSubscribe) for advanced cases (such as custom operators)

Returns:

an Observable that emits the same items as the source Observable, then invokes the Action0
rx.Observable.finallyDo
(Action0
an Action0 to be invoked when the source Observable finishes
action
)

use doAfterTerminate(Action0) instead.

Returns:

an Observable that emits GroupedObservables, each of which corresponds to a unique key value and each of which emits those items from the source Observable that share that key value
rx.Observable.groupBy
(final Func1<? super T, ? extends K>
a function that extracts the key for each item
keySelector
,
final Func1<? super T, ? extends R>
a function that extracts the return element for each item
elementSelector
,
final Func1<Action1<K>, Map<K, Object>>
a function that given an eviction action returns a Map instance that will be used to assign items to the appropriate GroupedObservables. The Map instance must be thread-safe and any eviction must trigger a call to the supplied action (synchronously or asynchronously). This can be used to limit the size of the map by evicting keys by maximum size or access time for instance. Here's an example using Guava's CacheBuilder from v19.0:
           Func1<Action1<K>, Map<K, Object>> mapFactory
             = action -> CacheBuilder.newBuilder()
                 .maximumSize(1000)
                 .expireAfterAccess(12, TimeUnit.HOURS)
                 .removalListener(notification -> action.call(notification.getKey()))
                 .<K, Object> build().asMap();
           
           
evictingMapFactory
)

since 1.3.7, use groupBy(Func1, Func1, int, boolean, Func1) instead which uses much less memory. Please take note of the usage difference involving the evicting action which now expects the value from the map instead of the key.

Returns:

an Observable that emits a 0L after the initialDelay and ever increasing numbers after each period of time thereafter
rx.Observable.timer
(long
the initial delay time to wait before emitting the first value of 0L
initialDelay
,
long
the period of time between emissions of the subsequent numbers
period
,
TimeUnit
the time unit for both initialDelay and period
unit
)

use interval(long, long, TimeUnit) instead

Returns:

an Observable that emits a 0L after the initialDelay and ever increasing numbers after each period of time thereafter, while running on the given Scheduler
rx.Observable.timer
(long
the initial delay time to wait before emitting the first value of 0L
initialDelay
,
long
the period of time between emissions of the subsequent numbers
period
,
TimeUnit
the time unit for both initialDelay and period
unit
,
Scheduler
the Scheduler on which the waiting happens and items are emitted
scheduler
)

use interval(long, long, TimeUnit, Scheduler) instead

rx.Single.Single(final Observable.OnSubscribe<T>
f to be executed when execute(SingleSubscriber) or subscribe(Subscriber) is called
f
)

1.2.1: Not recommended, use Single(OnSubscribe) to avoid wrapping and conversion between the Observable and Single protocols.

rx.exceptions.CompositeException.CompositeException(String
the prefix to use (actually unused)
messagePrefix
,
Collection<? extends Throwable>
the collection of errors
errors
)

please use CompositeException(Collection)

rx.internal.operators.OperatorGroupBy<
the source and group value type
T
,
the key type
K
,
the value type of the groups
V
>

since 1.3.7, use OperatorGroupByEvicting instead

rx.observers.TestObserver<
the observed value type
T
>

use the TestSubscriber instead.

Returns:

a list of Notifications representing calls to this Subscriber's onCompleted method
rx.observers.TestSubscriber.getOnCompletedEvents
()

use getCompletions() instead.

Returns:

rx.Completable.OnSubscribe function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaCompletableExecutionHook.onCreate
(Completable.OnSubscribe
original rx.Completable.OnSubscribe<T> to be executed
f
)

Returns:

rx.Completable.Operator<R, T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaCompletableExecutionHook.onLift
(final Completable.Operator lift)

Returns:

Throwable that can be decorated, replaced or just returned as a pass through
rx.plugins.RxJavaCompletableExecutionHook.onSubscribeError
(Throwable e)

Returns:

rx.Completable.OnSubscribe<T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaCompletableExecutionHook.onSubscribeStart
(Completable
the target completable instance
completableInstance
,
final Completable.OnSubscribe
original rx.Completable.OnSubscribe<T> to be executed
onSubscribe
)

Returns:

OnSubscribe<T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaObservableExecutionHook.onCreate
(Observable.OnSubscribe<T>
original OnSubscribe<T> to be executed
f
)

Returns:

Operator<R, T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaObservableExecutionHook.onLift
(final Observable.Operator<? extends R, ? super T>
original Operator<R, T>
lift
)

Returns:

Throwable that can be decorated, replaced or just returned as a pass through
rx.plugins.RxJavaObservableExecutionHook.onSubscribeError
(Throwable e)

Returns:

Subscription subscription that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaObservableExecutionHook.onSubscribeReturn
(Subscription
original Subscription
subscription
)

Returns:

OnSubscribe<T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaObservableExecutionHook.onSubscribeStart
(Observable<? extends T>
the parent observable instance
observableInstance
,
final Observable.OnSubscribe<T>
original OnSubscribe<T> to be executed
onSubscribe
)

Returns:

the single RxJavaPlugins instance
rx.plugins.RxJavaPlugins.getInstance
()

use the static methods of RxJavaHooks.

Returns:

wrapped action to schedule
rx.plugins.RxJavaSchedulersHook.onSchedule
(Action0
action to schedule
action
)

Returns:

rx.Single.OnSubscribe<T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaSingleExecutionHook.onCreate
(Single.OnSubscribe<T>
original rx.Single.OnSubscribe<T> to be executed
f
)

Returns:

rx.Observable.Operator<R, T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaSingleExecutionHook.onLift
(final Observable.Operator<? extends R, ? super T>
original rx.Observable.Operator<R, T>
lift
)

Returns:

Throwable that can be decorated, replaced or just returned as a pass through
rx.plugins.RxJavaSingleExecutionHook.onSubscribeError
(Throwable
Throwable thrown by Single#subscribe(Subscriber)
e
)

Returns:

Subscription subscription that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaSingleExecutionHook.onSubscribeReturn
(Subscription
original Subscription
subscription
)

Returns:

rx.Observable.OnSubscribe<T> function that can be modified, decorated, replaced or just returned as a pass through
rx.plugins.RxJavaSingleExecutionHook.onSubscribeStart
(Single<? extends T>
the parent single instance
singleInstance
,
final Observable.OnSubscribe<T>
original rx.Observable.OnSubscribe<T> to be executed
onSubscribe
)

rx.schedulers.ImmediateScheduler

This type was never publicly instantiable. Use Schedulers#immediate().

rx.schedulers.NewThreadScheduler

This type was never publicly instantiable. Use Schedulers#newThread().

rx.schedulers.TrampolineScheduler

This type was never publicly instantiable. Use Schedulers#trampoline().