system.reactive – 相当于ReactiveCocoa的RACObserve的RxJava(或Rx.NET)

给定 Java对象上的任意字段,我想创建一个Observable,它将监视该字段并在每次字段值更改时将新结果推送到Observer. ReactiveCocoa有一个名为RACObserve的宏,它似乎就是这样做的.

我想知道如何使用RxJava实现类似的功能.

例如,假设我有以下简单类：

public class Foo {
    enum State {
        Idle,Ready,Error
    }

    private State currentState = State.Idle;

    //methods that can change currentState
}

我想创建一个Observable< State>每次更改currentState的值时,都会将新状态推送到Observer.

在ReactiveCocoa中,看起来我会写下类似的东西(请原谅我的伪Objective-C)：

[RACObserve(self,currentState) subscribeNext:^(Nsstring *newState) {
    NSLog(@"%@",newState);
}];

我如何在RxJava中实现类似的功能？我想我可能需要在setter中包含对currentState的所有更改,但是我不清楚我应该在哪里调用Observable.create以及如何将currentState的更改提供给Observer.

ReactiveCocoa实际上与ReactiveUI( http://www.reactiveui.net)更相似,而不仅仅是普通的Rx.在ReactiveUI中,您可以使用this.WhenAnyValue(x => x.PropName)来完成您想要的操作.