Replaced IncrementalCallback with full RxJava-style Observer support