我正在尝试用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)
拜托,有人能帮我解决这个错误吗?非常感谢!
发布于 2018-06-28 09:58:54
您正在将结构混合在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();
}
}
);
}
}
发布于 2018-06-28 09:35:34
您确定类路径上有正确版本的RxJava吗?看起来您正在尝试使用RxJava 1.x (io.reactivex.Observable
),但是Observable.OnSubscribe
是在RxJava 2.x (rx.Observable
)中添加的
https://stackoverflow.com/questions/51088551
复制