com.rxc

Class UnsafeObservableBuilder<T>

java.lang.Object

com.rxc.UnsafeObservableBuilder<T>

Type Parameters:

T - The class for the Observable

public final class UnsafeObservableBuilder<T>
extends java.lang.Object

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. All events given to the builder will be performed on the Subscriber, even if the Subscriber would normally terminate. This also allows the Observable to emit more than one error, or complete more than once. Though in order for the subscriber to be called in such a manner you must subscribe with Observable.unsafeSubscribe() You should not be using this unless you purposefully are violating the RX Observable contract, or are testing odd situations Instead use ObservableBuilder, which enforces a proper RX Observable contract

Constructor Summary

Constructors

Constructor and Description
UnsafeObservableBuilder()

Method Summary

Modifier and Type	Method and Description
rx.Observable<T>	build() Returns an Observable the performs all event's given to the builder when subscribed to
UnsafeObservableBuilder<T>	complete() 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
UnsafeObservableBuilder<T>	emit(T item) Adds a new event to the observable that emits the given item
UnsafeObservableBuilder<T>	error(java.lang.Throwable error) 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
UnsafeObservableBuilder<T>	notify(rx.Notification<T> notification) Adds a bew event that performs the given Notification through the Observable
UnsafeObservableBuilder<T>	perform(rx.functions.Action1<rx.Subscriber<? super T>> action) Adds a new event to the observable that performs the specified action on the subscription
UnsafeObservableBuilder<T>	perform(java.lang.Runnable runnable) Adds a new event to the observable that runs the specified runnable
UnsafeObservableBuilder<T>	sleep(long mills) Adds a new event to the observable that will delay all further event's by the specified amount of time

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnsafeObservableBuilder

public UnsafeObservableBuilder()

Method Detail

emit

public UnsafeObservableBuilder<T> emit(T item)

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

Parameters:

item - The item to emit

Returns:

The builder to build the rest of the observable with

error

public UnsafeObservableBuilder<T> error(java.lang.Throwable error)

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

Parameters:

error - The error

Returns:

The builder to build the rest of the observable with

complete

public UnsafeObservableBuilder<T> complete()

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

Returns:

The Observable that will emit the defined events when subscribed to

sleep

public UnsafeObservableBuilder<T> sleep(long mills)

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

Parameters:

mills - How long to delay in milliseconds

Returns:

The builder to build the rest of the observable with

notify

public UnsafeObservableBuilder<T> notify(rx.Notification<T> notification)

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

Parameters:

notification - The Notification to perform

Returns:

The builder to build the rest of the observable with

perform

public UnsafeObservableBuilder<T> perform(rx.functions.Action1<rx.Subscriber<? super T>> action)

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

Parameters:

action - The action to be performed

Returns:

The builder to build the rest of the observable with

perform

public UnsafeObservableBuilder<T> perform(java.lang.Runnable runnable)

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

Parameters:

runnable - The runnable to run

Returns:

The builder to build the rest of the observable with

build

public rx.Observable<T> build()

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

Returns:

The Observable