RxJava Artikel auf Anfrage laden

Question

Ich möchte den/die nächsten Artikel laden, wenn ein anderes Observable einen neuen Gegenstand (einen Auslöser) auslöst.

Dies ist der Code, der die Elemente emittiert: Ich konnte dieses Problem umgehen, war mit einem Subject und hält einen Verweis auf eine Liste von

RxView.clicks(view.findViewById(R.id.button_more)).debounce(500, TimeUnit.MILLISECONDS); 

Der einzige Weg:

public Observable<Item> get() { 
    return idApi.get().flatMap(new Function<List<String>, ObservableSource<String>>() { 
     @Override 
     public ObservableSource<String> apply(@NonNull List<String> ids) throws Exception { 
      return Observable.fromIterable(ids); 
     } 
    }).flatMap(new Function<String, ObservableSource<Item>>() { 
     @Override 
     public ObservableSource<Item> apply(@NonNull final String id) throws Exception { 
      return dataApi.get(id).map(new Function<Data, Item>() { 
       @Override 
       public Item apply(@NonNull Data data) throws Exception { 
        return new Item(data , id); 
      }); 
     } 
    }); 
} 

Trigger-Observable ids, die nicht elegant war und nicht reagierte.

Edit: Das ist meine Lösung bisher, aber ich musste abonnieren Ereignis direkt zu abonnieren. Ich halte das nicht für elegant.

@Override 
public Observable<Item> get(final Observable<Object> trigger) { 
    final PublishSubject<Item> subject = PublishSubject.create(); 
    return idApi.get().flatMap(new Function<List<String>, ObservableSource<Queue<String>>>() { 
     @Override 
     public ObservableSource<Queue<String>> apply(@NonNull List<String> ids) throws Exception { 
      final Queue<String> q = new LinkedList<>(ids); 
      return Observable.just(q); 
     } 
    }).flatMap(new Function<Queue<String>, ObservableSource<Item>>() { 
     @Override 
     public ObservableSource<Item> apply(@NonNull final Queue<String> ids) throws Exception { 
      trigger.subscribeOn(AndroidSchedulers.mainThread()).subscribe(new Consumer<Object>() { 
       @Override 
       public void accept(@NonNull Object o) throws Exception { 
        if (ids.size() > 0) { 
         final String id = ids.poll(); 
         dataApi.get(id).map(new Function<Data, Item>() { 
          @Override 
          public Item apply(@NonNull Data data) throws Exception { 
           return new Item(data, id) l 
          } 
         }).subscribe(new Consumer<Item>() { 
          @Override 
          public void accept(@NonNull Item item) throws Exception { 
           subject.onNext(item); 
          } 
         }); 
        } else { 
         subject.onComplete(); 

        } 
       } 
      }); 
      return subject; 
     } 
    }); 
} 

Answer 1

Verwenden zip

public Observable<Item> get(View v) { 
    return idApi.get().flatMap(new Function<List<String>, ObservableSource<String>>() { 
     @Override 
     public ObservableSource<String> apply(@NonNull List<String> ids) throws Exception { 
      return Observable.fromIterable(ids); 
     } 
    }).zipWith(RxView.clicks(v).debounce(500, TimeUnit.MILLISECONDS), (n, i) -> n))  
    .flatMap(new Function<String, ObservableSource<Item>>() { 
     @Override 
     public ObservableSource<Item> apply(@NonNull final String id) throws Exception { 
      return dataApi.get(id).map(new Function<Data, Item>() { 
       @Override 
       public Item apply(@NonNull Data data) throws Exception { 
        return new Item(data , id); 
      }); 
     } 
    }); 
} 

bekommen N Artikel mit jedem Klick

public Observable<Item> getN(View v, int nitems) { 
    return idApi.get().flatMap(new Function<List<String>, ObservableSource<String>>() { 
      @Override 
      public ObservableSource<String> apply(@NonNull List<String> ids) throws Exception { 
       return Observable.fromIterable(ids); 
      } 
     }).buffer(nitems).zipWith(RxView.clicks(v).debounce(500, TimeUnit.MILLISECONDS), (n, i) -> n)) 
     .flatMap(new Function<List<String>, ObservableSource<String>>() { 
      @Override 
      public ObservableSource<String> apply(@NonNull final List<String> ids) throws Exception { 
       return Observable.from(ids) 
      } 
     } 
     ) 
     .flatMap(new Function<String, ObservableSource<Item>>() { 
      @Override 
      public ObservableSource<Item> apply(@NonNull final String id) throws Exception { 
       return dataApi.get(id).map(new Function<Data, Item>() { 
        @Override 
        public Item apply(@NonNull Data data) throws Exception { 
         return new Item(data , id); 
       }); 
       } 
     } 
     }); 
} 

Edit: Sie werden noch subscribeOn verwenden, um sicherzustellen, dass Sie auf dem Hauptthread für RxView .clicks und auf dem IO-Thread für jedes Netzwerk.

Answer 2

Nicht so gut, aber es funktioniert:

Ihre get-Methode:

Observable<Item> get(final String id){ 
    return Observable.defer(() -> { 
    dataApi.get(id).map(new Function<Data, Item>() { 
      @Override 
      public Item apply(@NonNull Data data) throws Exception { 
       return new Item(data , id); 
     }); 
    }) 
} 

Ihr Klick:

private List<String> ids = {//your id s} 
private int current = 0; 

RxView.clicks(view).flatmap(ignore -> get(ids.get(current++))) 
        .subscribe(//your Observer) 

Ich mag würde diese Antwort mit zipwith() empfehlen, scheint besser als meine Antworten.