Così poche settimane fa ho posto questa domanda: recyclerview periodic ui child updates.Utilizzo di RxJava nell'adattatore RecyclerView
E oggi voglio refactoring quella funzionalità utilizzando Rxjava. In realtà è piuttosto semplice, realizzo il seguente modo:
@Override
public void onBindViewHolder(RecyclerView.ViewHolder holder, int position) {
if (friend.getGameStatus().equals(GameStatus.INGAME)) {
holderOnline.startRepeatingTask();
} else {
holderOnline.stopRepeatingTask();
}
}
class MyViewHolderOnline extends RecyclerView.ViewHolder {
private Subscription subscribe;
public MyViewHolderOnline(View itemView) {
super(itemView);
ButterKnife.bind(this, itemView);
}
public void startRepeatingTask() {
subscribe = Observable.interval(updateInterval, TimeUnit.MILLISECONDS)
.map(aLong -> current.getGameStatusToPrint())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<String>() {
@Override public void onCompleted() { }
@Override public void onError(Throwable e) { }
@Override
public void onNext(String gameStatusToPrint) {
gameStatus.setText(gameStatusToPrint);
}
});
}
void stopRepeatingTask() {
if(subscribe != null && !subscribe.isUnsubscribed())
subscribe.unsubscribe();
}
}
Il problema tuttavia è diverso. Ho un navigationDrawer implementato con le attività che sono in pausa e non distrutto quando commutato. Quindi, dopo che passo all'attività che non contiene questo adattatore, l'osservabile continua a inviare roba perché è un intervallo periodico osservabile. Quindi la mia domanda è: cosa dovrei fare? Ho bisogno di disiscriverti quando l'attività è in pausa, ma non ho idea di come da allora, e anche come iscriversi indietro. Qualche aiuto o idee?
o dovrei semplicemente controllare su Next e non fare nulla se l'attività è in pausa? –