Eine ausführliche Erläuterung der Techniken von RxJava_04 [Datenübertragungsfilterungsvorgang]-javaLernprogramm-php.cn

Dieses Tutorial basiert auf RxJava1 >Wenn der Beobachter Daten an den Beobachter sendet, müssen die Daten möglicherweise während der Datenübertragung weiter gefiltert werden. Das folgende Tutorial behandelt Funktionen für die meisten Filtervorgänge.
Eindeutig – doppelt gesendete Daten entfernen

Es gibt jetzt eine Klasse und die Informationen der Schüler wurden in das Schülersystem eingegeben. Es stellte sich heraus, dass dieselben Daten wiederholt wurden. Die Schülerdatenwarteschlange sieht wie folgt aus:

Der aktuelle Bedarf besteht darin, Objekte mit doppelten Namen abzufangen. Und drucken Sie es aus:

Die Ausgabe ist wie folgt:

private ArrayList<Student> initPersons() {
    ArrayList<Student> persons = new ArrayList<>();
    persons.add(new Student("张三", 16));
    persons.add(new Student("李四", 17));
    persons.add(new Student("王二麻子", 18));
    persons.add(new Student("张三", 22));
    return persons;
}

Nach dem Login kopieren

2.Filter

Observable
    .from(initPersons())
    //过滤重复名字的项
    .distinct(new Func1<Student, String>() {
        @Override
        public String call(Student student) {
            return student.name;
        }
    })
    .subscribe(new Action1<Student>() {
        @Override
        public void call(Student student) {
            Log.i(TAG, "call: "+student);
        }
    });

Nach dem Login kopieren

Zusätzlich zum Herausfiltern der wiederholten Teile der übertragenen Daten Sie können auch den Filter „Bestimmte Daten basierend auf Regeln löschen“ verwenden.

Die vom folgenden Code gesendeten Daten sind 12345. Die Filterregel besagt, dass der Datenbalken kleiner als 4 sein muss. Der Beispielcode lautet wie folgt:

IT520: call: Student{name=&#39;张三&#39;, age=16}
IT520: call: Student{name=&#39;李四&#39;, age=17}
IT520: call: Student{name=&#39;王二麻子&#39;, age=18}

Nach dem Login kopieren

Ausgabe

3 .First

Observable.just(1, 2, 3, 4, 5)
      .filter(new Func1<Integer, Boolean>() {
          @Override
          public Boolean call(Integer item) {
            return( item < 4 );
          }
      })
      .subscribe(new Subscriber<Integer>() {
            @Override
            public void onNext(Integer item) {
                System.out.println("Next: " + item);
            }

            @Override
            public void onError(Throwable error) {
                System.err.println("Error: " + error.getMessage());
            }

            @Override
            public void onCompleted() {
                System.out.println("Sequence complete.");
            }
        });

Nach dem Login kopieren

Durch den Aufruf dieser Funktion kann die Warteschlange für gesendete Daten nur das erste Element senden.

Beispielcode

Next: 1
Next: 2
Next: 3
Sequence complete.

Nach dem Login kopieren

Ausgabe

Ähnliche Funktionen umfassen firstOrDefault(), das in die Warteschlange gesendet wird, wenn die Warteschlange null ist Das heißt, wenn das erste Element nicht gefunden wird, wird ein Standardwert gesendet.

Observable.just(1, 2, 3)
      .first()
      .subscribe(new Subscriber<Integer>() {
    @Override
    public void onNext(Integer item) {
        System.out.println("Next: " + item);
    }

    @Override
    public void onError(Throwable error) {
        System.err.println("Error: " + error.getMessage());
    }

    @Override
    public void onCompleted() {
        System.out.println("Sequence complete.");
    }
});

Nach dem Login kopieren

4.Last

Next: 1
Sequence complete.

Nach dem Login kopieren

Rufen Sie diese Funktion auf, um nur das letzte Element in der Warteschlange für gesendete Daten zu senden. Beispielcode

Ausgabe

Ähnliche Funktionen umfassen lastOrDefault(T)

Observable.just(1, 2, 3)
      .last()
      .subscribe(new Subscriber<Integer>() {
    @Override
    public void onNext(Integer item) {
        System.out.println("Next: " + item);
    }

    @Override
    public void onError(Throwable error) {
        System.err.println("Error: " + error.getMessage());
    }

    @Override
    public void onCompleted() {
        System.out.println("Sequence complete.");
    }
});

Nach dem Login kopieren

Next: 3
Sequence complete.

Nach dem Login kopieren

Der ElementAt-Operator ruft das Datenelement an der angegebenen Indexposition der vom ursprünglichen Observable ausgegebenen Datensequenz ab und gibt es dann als eigene eindeutige Daten aus. Wenn Sie eine negative Zahl übergeben oder die Anzahl der Datenelemente im ursprünglichen Observable kleiner als index+1 ist, wird eine IndexOutOfBoundsException ausgelöst.

Der Beispielcode lautet wie folgt:

Ausgabe

6.Take

Observable.just(1, 2, 3, 4, 1, 4)
    .elementAt(3)
    .subscribe(new Action1<Integer>() {
        @Override
        public void call(Integer value) {
            Log.i(TAG, "call: " + value);
        }
    });

Nach dem Login kopieren

Mit dem Take-Operator können Sie die ändern Verhalten des Observable: Nur die ersten N Datenelemente werden zurückgegeben, dann wird die Abschlussbenachrichtigung ausgegeben und die verbleibenden Daten werden ignoriert.

Beispielcode

com.m520it.rxjava I/IT520: call: 4

Nach dem Login kopieren

Ausgabe

7.TakeLast

Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
      .take(4)
      .subscribe(new Subscriber<Integer>() {
            @Override
            public void onNext(Integer item) {
                System.out.println("Next: " + item);
            }

            @Override
            public void onError(Throwable error) {
                System.err.println("Error: " + error.getMessage());
            }

            @Override
            public void onCompleted() {
                System.out.println("Sequence complete.");
            }
        });

Nach dem Login kopieren

Verwenden Sie den TakeLast-Operator, um das ursprüngliche Observable zu ändern. Sie können es einfach ausgeben Die letzten N übertragenen Daten werden ignoriert. Die vorherigen Daten werden ignoriert.

Beispielcode

Next: 1
Next: 2
Next: 3
Next: 4
Sequence complete.

Nach dem Login kopieren

Ausgabe

8.Sample

Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
      .takeLast(4)
      .subscribe(new Subscriber<Integer>() {
            @Override
            public void onNext(Integer item) {
                System.out.println("Next: " + item);
            }

            @Override
            public void onError(Throwable error) {
                System.err.println("Error: " + error.getMessage());
            }

            @Override
            public void onCompleted() {
                System.out.println("Sequence complete.");
            }
        });

Nach dem Login kopieren

Sample die gesendeten Daten in einer bestimmten Häufigkeit

Next: 5
Next: 6
Next: 7
Next: 8
Sequence complete.

Nach dem Login kopieren

Der obige Code gibt aus: 0, 2, 4, 6, 8. . . .

9.IgnoreElements

Wenn Ihnen die von einem Observable ausgegebenen Daten egal sind, Sie aber benachrichtigt werden möchten, wenn es abgeschlossen wird oder mit einem Fehler endet, können Sie den Operator „ignoreElements“ verwenden Das Observable stellt sicher, dass die onNext()-Methode des Beobachters niemals aufgerufen wird.

Observable
        .interval(1000, TimeUnit.MILLISECONDS)//每秒发送1个数字
        .sample(2000,TimeUnit.MILLISECONDS)//每2秒采样一次
        .subscribe(new Action1<Long>() {
            @Override
            public void call(Long aLong) {
                Log.i(TAG, "call: "+aLong);
            }
        });

Nach dem Login kopieren

Das Obige ist eine ausführliche Einführung in die Techniken von RxJava_04 [Datenübertragungsfilterungsvorgang]. Weitere verwandte Inhalte finden Sie auf der chinesischen PHP-Website (m.sbmmt.com)!

Observable.just(1, 2, 3, 4, 1)
            .ignoreElements()//不发送任何信息 直接发送onCompleted()
            .subscribe(new Subscriber<Integer>() {
                @Override
                public void onCompleted() {
                    Log.i(TAG, "onCompleted: ");
                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onNext(Integer integer) {
                    Log.i(TAG, "onNext: "+integer);
                }
            });

Nach dem Login kopieren