com.rxc

Class ObservableBuilder<T>

java.lang.Object

com.rxc.ObservableBuilder<T>

Type Parameters:

T - The class for the Observable

public class ObservableBuilder<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

Constructor Summary

Constructors

Constructor and Description
ObservableBuilder()

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
rx.Observable<T>	complete() Builds an Observable that performs all previous events and lastly terminates by telling it's subscribers that it completed
ObservableBuilder<T>	emit(T item) Adds a new event to the observable that emits the given item
rx.Observable<T>	error(java.lang.Throwable error) Builds an Observable that performs all previous events and lastly terminates with the given error
ObservableBuilder<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
ObservableBuilder<T>	perform(java.lang.Runnable runnable) Adds a new event to the observable that runs the specified runnable
ObservableBuilder<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

ObservableBuilder

public ObservableBuilder()

Method Detail

emit

public ObservableBuilder<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 rx.Observable<T> error(java.lang.Throwable error)

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

Parameters:

error - The error

Returns:

The final Observable

complete

public rx.Observable<T> complete()

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

Returns:

The final Observable

sleep

public ObservableBuilder<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

perform

public ObservableBuilder<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 ObservableBuilder<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