RxJava - Criando Observáveis
A seguir estão as classes básicas para criar observáveis.
Flowable- 0..N flui, emite 0 ou n itens. Suporta fluxos reativos e contrapressão.
Observable - 0..N flui, mas sem contrapressão.
Single- 1 item ou erro. Pode ser tratado como uma versão reativa da chamada de método.
Completable- Nenhum item emitido. Usado como um sinal de conclusão ou erro. Pode ser tratado como uma versão reativa do Runnable.
MayBe- Nenhum item ou 1 item emitido. Pode ser tratada como uma versão reativa de Opcional.
A seguir estão os métodos convenientes para criar observáveis na classe Observable.
just(T item) - Retorna um Observable que sinaliza o item fornecido (referência constante) e então é concluído.
fromIterable(Iterable source) - Converte uma sequência Iterable em um ObservableSource que emite os itens na sequência.
fromArray(T... items) - Converte um Array em um ObservableSource que emite os itens do Array.
fromCallable(Callable supplier) - Retorna um Observable que, quando um observador se inscreve nele, invoca uma função que você especifica e emite o valor retornado dessa função.
fromFuture(Future future) - Converte um futuro em uma fonte observável.
interval(long initialDelay, long period, TimeUnit unit) - Retorna um Observable que emite 0L após o initialDelay e números crescentes após cada período de tempo posterior.