Wie wird mit RxJava mit Paging umgegangen?

Ich möchte meine Android-App konvertieren, um Rxjava für Netzwerkanforderungen zu verwenden. Ich greife derzeit auf einen Webservice zu, der dem folgenden ähnelt:

getUsersByKeyword(String query, int limit, int offset)

Soweit ich weiß, handelt es sich bei Observables eher um eine Push- als um eine Pull-Schnittstelle. So verstehe ich Dinge, die zu klären sind:

app registriert sich beim Dienst und wird für die Abfrage "Observable" (beobachtbarErgebnisse werden an die App @ weitergeleitapp befasst sich mit ErgebnissenWenn App mehr Ergebnisse will ...?

Das ist, wo die Dinge für mich zusammenbrechen. Früher habe ich nur den Webservice nach genau dem gefragt, was ich möchte, und die Abfrage erneut mit dem Offset durchgeführt. In diesem Fall müsste jedoch ein weiteres Observable erstellt und abonniert werden, um den Punkt zu umgehen.

Wie soll ich mit Paging in meiner App umgehen? (Es ist eine Android-App, aber ich halte das nicht für relevant.)

Antworten auf die Frage(4)

Ihre Antwort auf die Frage