A B C D E N O P S U

A

add(Subscription) - Method in class com.rxc.DisposeBag

Adds a subscription to the DisposeBag

addAll(Iterable<Subscription>) - Method in class com.rxc.DisposeBag

Adds a collection of subscriptions to the DisposeBag

B

build() - Method in class com.rxc.ObservableBuilder

Returns an Observable the performs all event's given to the builder when subscribed to

build() - Method in class com.rxc.UnsafeObservableBuilder

Returns an Observable the performs all event's given to the builder when subscribed to

C

com.rxc - package com.rxc

complete() - Method in class com.rxc.ObservableBuilder

Builds an Observable that performs all previous events and lastly terminates by telling it's subscribers that it completed

complete() - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event that notifies all subscribers that the Observable has completed All further events will still be performed on the subscriber even though it's terminated

D

disposeAll() - Method in class com.rxc.DisposeBag

Unsubscribes all added subscribers that are still subscribed and haven't been garbage collected The DisposeBag is still usable after this method is called An attempt to unsubscribe is made on every subscription in the DisposeBag, even if a subscription throws If any subscriptions do throw they are removed from the dispose bag and a Composite exception is thrown that contains all throws at the end of the disposal process

DisposeBag - Class in com.rxc

A simple system for tearing down subscriptions in a memory efficient and re-usable manner DisposeBag allows you to add as many subscriptions as you like, perform you can call disposeAll() to unsubscribe all added subscriptions.

DisposeBag() - Constructor for class com.rxc.DisposeBag

E

emit(T) - Method in class com.rxc.ObservableBuilder

Adds a new event to the observable that emits the given item

emit(T) - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event to the observable that emits the given item

error(Throwable) - Method in class com.rxc.ObservableBuilder

Builds an Observable that performs all previous events and lastly terminates with the given error

error(Throwable) - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event to the observable that errors using the given error All further events will still be performed on the subscriber even though it's terminated

N

notify(Notification<T>) - Method in class com.rxc.UnsafeObservableBuilder

Adds a bew event that performs the given Notification through the Observable

O

ObservableBuilder<T> - Class in com.rxc

A builder to build up an Observable that performs a set of events on it's Subscribers This is the unsafe builder, meant for testing odd circumstances and working with Observables that don't follow the strict contract.

ObservableBuilder() - Constructor for class com.rxc.ObservableBuilder

P

perform(Action1<Subscriber<? super T>>) - Method in class com.rxc.ObservableBuilder

Adds a new event to the observable that performs the specified action on the subscription

perform(Runnable) - Method in class com.rxc.ObservableBuilder

Adds a new event to the observable that runs the specified runnable

perform(Action1<Subscriber<? super T>>) - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event to the observable that performs the specified action on the subscription

perform(Runnable) - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event to the observable that runs the specified runnable

S

sleep(long) - Method in class com.rxc.ObservableBuilder

Adds a new event to the observable that will delay all further event's by the specified amount of time

sleep(long) - Method in class com.rxc.UnsafeObservableBuilder

Adds a new event to the observable that will delay all further event's by the specified amount of time

U

UnsafeObservableBuilder<T> - Class in com.rxc

A builder to build up an Observable that performs a set of events on it's Subscribers This is the unsafe builder, meant for testing odd circumstances and working with Observables that don't follow the strict contract.

UnsafeObservableBuilder() - Constructor for class com.rxc.UnsafeObservableBuilder

A B C D E N O P S U