org.dc.riot.lol.rx.service

Class ObservableFactory<T>

java.lang.Object

org.dc.riot.lol.rx.service.ObservableFactory<T>

Type Parameters:

T - generic type

public class ObservableFactory<T>
extends java.lang.Object

Factory helper to create functional Observable instances. Typical use case for this class is to help in creating the first Observable in a chain.

 
	RiotApi.Champion champInterface = factory.newChampionInterface(region, true);
	ObservableFactory.create(() -> {
		return champInterface.getChampions(true);
	})
	.subscribe((ChampionListDto dto) -> {
		... Process champions ...
	},
	(Throwable e) -> {
		e.printStackTrace();
	},
	() -> {
		System.out.println("Done");
	});
 

Since:

1.0.0

Method Summary

Modifier and Type	Method and Description
static <T> rx.Observable<T>	create(java.util.concurrent.Callable<T> callable)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static <T> rx.Observable<T> create(java.util.concurrent.Callable<T> callable)

Type Parameters:

T - generic type

Parameters:

callable - Callable that should make a single API call and return the result. We use Callable instead of Supplier for the exception handling.

Returns:

an Observable that will emit the object returned by callable