RxJava - Criando Operadores

A seguir estão os operadores que são usados ​​para criar um Observable.

Sr. Não. Operador e descrição
1

Create

Cria um Observable do zero e permite que o método do observador chame programaticamente.

2

Defer

Não crie um Observable até que um observador se inscreva. Cria um novo observável para cada observador.

3

Empty/Never/Throw

Cria um observável com comportamento limitado.

4

From

Converte uma estrutura de objeto / dados em um Observable.

5

Interval

Cria um número inteiro de emissão observável em sequência com um intervalo de intervalo de tempo especificado.

6

Just

Converte uma estrutura de objeto / dados em um Observable para emitir o mesmo ou o mesmo tipo de objetos.

7

Range

Cria um número inteiro de emissão observável na sequência de um determinado intervalo.

8

Repeat

Cria um observável emitindo inteiros em sequência repetidamente.

9

Start

Cria um Observable para emitir o valor de retorno de uma função.

10

Timer

Cria um Observable para emitir um único item após um determinado atraso.

Criando exemplo de operador

Crie o seguinte programa Java usando qualquer editor de sua escolha em, digamos, C: \> RxJava.

ObservableTester.java

import io.reactivex.Observable;
//Using fromArray operator to create an Observable
public class ObservableTester  {
   public static void main(String[] args) { 
      String[] letters = {"a", "b", "c", "d", "e", "f", "g"};
      final StringBuilder result = new StringBuilder();
      Observable<String> observable = Observable.fromArray(letters);
      observable
         .map(String::toUpperCase)
         .subscribe( letter -> result.append(letter));
      System.out.println(result);
   }
}

Verifique o resultado

Compile a classe usando javac compilador da seguinte forma -

C:\RxJava>javac ObservableTester.java

Agora execute o ObservableTester da seguinte maneira -

C:\RxJava>java ObservableTester

Ele deve produzir a seguinte saída -

ABCDEFG