Android Rxjava einer Variablen ändern abonnieren

Question

I Observer Muster lerne, möchte ich meine beobachtbaren Spur einer bestimmten Variablen zu halten, wenn es seinen Wert ändert und einige Operationen zu tun, ich habe getan, so etwas wie:

public class Test extends MyChildActivity { 

    private int VARIABLE_TO_OBSERVE = 0; 

    Observable<Integer> mObservable = Observable.just(VARIABLE_TO_OBSERVE); 

    protected void onCreate() {/*onCreate method*/ 
     super(); 
     setContentView(); 
     method(); 
     changeVariable(); 
    } 

    public void changeVariable() { 
     VARIABLE_TO_OBSERVE = 1; 
    } 

    public void method() { 
     mObservable.map(value -> { 
      if (value == 1) doMethod2(); 
      return String.valueOf(value); 
     }).subScribe(string -> System.out.println(string)); 
    } 

    public void doMethod2() {/*Do additional operations*/} 

} 

Aber doMethod2() wird nicht aufgerufen

Answer 1

Nichts ist Magie im Leben: Wenn Sie einen Wert aktualisieren, wird Ihre Observable wird nicht benachrichtigt. Du musst es selbst machen. Zum Beispiel mit einem PublishSubject.

public class Test extends MyChildActivity { 

    private int VARIABLE_TO_OBSERVE = 0; 

    Subject<Integer> mObservable = PublishSubject.create(); 

    protected void onCreate() {/*onCreate method*/ 
     super(); 
     setContentView(); 
     method(); 
     changeVariable(); 
    } 

    public void changeVariable() { 
     VARIABLE_TO_OBSERVE = 1; 
     // notify the Observable that the value just change 
     mObservable.onNext(VARIABLE_TO_OBSERVE); 
    } 

    public void method() { 
     mObservable.map(value -> { 
      if (value == 1) doMethod2(); 
      return String.valueOf(value); 
     }).subScribe(string -> System.out.println(string)); 
    } 

    public void doMethod2() {/*Do additional operations*/} 

} 

Answer 2

@dwursteisen Nichts ist Magie, nein, aber ich denke, dass wir es ein wenig mehr Magie als das bekommen ...

Wie wäre es ein Rx BehaviourSubject auf diese Weise mit:

import rx.functions.Action1; 
import rx.subjects.BehaviorSubject;  

public class BehaviourSubjectExample { 

    public BehaviourSubjectExample() { 
     subject.skip(1).subscribe(new Action1<Integer>() { 
      @Override 
      public void call(Integer integer) { 
       System.out.println("The value changed to " + integer); 
      } 
     }); 
    } 

    public final BehaviorSubject<Integer> subject = BehaviorSubject.create(0); 

    public int getValue()   { return subject.getValue(); } 
    public void setValue(int value) { subject.onNext(value);  } 
} 

Entfernen Sie die .skip(1), wenn der Beobachtungscode den Anfangswert anzeigen soll.

Der variable Hintergrund bleibt mit der BehaviourSubject und kann durch konventionelle Java Getter/Setter zugegriffen werden. Dies ist ein Spielzeug Beispiel natürlich: Wenn Ihr Anwendungsfall wirklich da diese einfache waren keine Entschuldigung wäre nicht nur für das Schreiben:

private int value = 0; 

public int getValue() { return value; } 
public void setValue(int value) { 
    this.value = value; 
    System.out.println("The value changed to " + value); 
} 

... aber die Verwendung von BehaviourSubject können Sie Brücke Änderungen an anderen Rx-Daten -Streams innerhalb Ihrer Klasse, um komplexere Verhaltensweisen zu erstellen.