RxJava。Observable.OnSubscribe 无法解析为类型

Question

我正在尝试用 RxJava 编写我的第一个代码，但我想我遇到了一些库导入错误。

package second.pack;
import io.reactivex.Observable;
public class Main {
    public static void main(String[] args) {
        Observable <String> observable = Observable.create(
// the line below marked as it has an error in Eclipse
/* 7 line */    new Observable.OnSubscribe<String>(){
                    @Override
                    public void call (Subscriber <String> sub){
                      sub.onNext("New Datas");
                      sub.onComplete(); 
                }
            }
    );
}

}

错误

Exception in thread "main" java.lang.Error: Unresolved compilation problem: 
    Observable.OnSubscribe cannot be resolved to a type
    at second.pack.Main.main(Main.java:7)

请问有人能帮我解决这个错误吗？非常感谢！

Answer 1

您正在混淆 1.x 和 2.x 之间的构造。您使用的是较旧的教程吗？试试这个：

import io.reactivex.*;

public class ObservableOnSubscribeTest {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(
                new ObservableOnSubscribe<String>(){
                    @Override
                    public void subscribe(ObservableEmitter<String> sub){
                        sub.onNext("New Datas");
                        sub.onComplete(); 
                    }
                }
            );
    }
}