ObservableZip .subscribe()崩溃:空指针异常，但是是什么导致的呢？
ObservableZip.subscribe()崩溃:空指针异常可能是由以下原因导致的：
- 空的Observable对象：当ObservableZip.subscribe()方法中传入的Observable对象为空时，会导致空指针异常。解决方法是确保传入的Observable对象不为空。
- 空的订阅者（Subscriber）对象：当ObservableZip.subscribe()方法中传入的订阅者对象为空时，会导致空指针异常。解决方法是确保传入的订阅者对象不为空。
- 空的观察者（Observer）对象：当ObservableZip.subscribe()方法中传入的观察者对象为空时，会导致空指针异常。解决方法是确保传入的观察者对象不为空。
- 空的数据源：当ObservableZip.subscribe()方法中传入的Observable对象中的数据源为空时，会导致空指针异常。解决方法是确保数据源不为空或者在代码中进行空值判断。
- 线程安全问题：ObservableZip.subscribe()方法在多线程环境下可能存在线程安全问题，导致空指针异常。解决方法是使用线程安全的Observable对象或者在代码中进行线程同步操作。
需要注意的是，以上仅是可能导致ObservableZip.subscribe()崩溃的一些常见原因，具体原因还需要根据实际代码和环境进行分析和排查。
相关·内容
1回答
AnonymousSafeObservable的用途是什么?创建它的时间/原因是什么？
system.reactive
我使用Where谓词和ObservableExtensions.Subscribe(this, Action<T>)方法订阅Observable。
当在订阅Action中抛出异常时，我可以在堆栈上看到一个名为AnonymousSafeObserver的类，这似乎是导致在订阅Action中的异常之后处理我的底层Observable的原因。
这不是我所期望的行为，也不是我以前在其他订阅中见过的行为，通常异常只是被传递给OnNext的调用者(即observable)。
这种类/行为是在什么情况下引入的？
浏览 0提问于2013-07-29得票数 0
1回答
对处理RxJava中的错误和异常感到困惑
android、rx-java
我刚刚开始学习RxJava，我读过很多教程，也看过不少教程，但有些东西还没有点击。我已经从深端潜入，并开始修改我的应用程序的API调用之一，以返回一个可观察的。当前，API调用由AsyncTaskLoader使用，它从本地数据库返回缓存的数据，然后执行调用，合并数据并再次返回数据。这个模式听起来像是我的RxJava实验的完美主题，但从小到小，我想从我的API调用中返回一个可以观察到的。
这是我最初的决定：
public static ArrayList<Stuff> getStuffForId(String id)
throws IOException, UserN
浏览 2提问于2016-11-06得票数 0
回答已采纳
2回答
多线程观察器的设计模式
multithreading、design-patterns、observer-pattern、dataflow
在数字信号采集系统中，数据通常由一个线程推送到系统中的观察者中。
来自的示例
foreach (IObserver observer in observers)
observer.Update(message);
例如，当来自GUI线程的用户操作需要停止数据流动时，您想要断开主体-观察者连接，甚至一起处理观察者。
有人可能会争辩说:您应该停止数据源，并等待一个标记值来处理连接。但这会在系统中产生更多的延迟。
当然，如果数据抽取线程刚刚请求观察者的地址，它可能会发现它正在向被销毁的对象发送消息。
有没有人创建了一个“官方”设计模式来应对这种情况？他们不应该这样做吗？
浏览 0提问于2008-09-17得票数 1
回答已采纳
1回答
在取消订阅函数中异步释放资源
javascript、rxjs、rxjs6
我想异步地处置一个observable的unsubscribe函数中的资源。例如：
// rxjs 6
let observable = Observable.create(sub => {
let resource = new Resource();
return {
async unsubscribe() {
await resource.dispose();
}
}
};
问题是，因为unsubscribe函数不应该返回Promise，所以不会有任何东西等待它，所以unsubscribe函数将在资源完
浏览 0提问于2018-09-17得票数 5
1回答
当我们在angular 7中不使用rxjs时，需要取消订阅吗
rxjs、angular7
我正在从api(在服务文件中)获取数据，并且在ts文件中订阅。我没有使用rxjs(observable和subscription) .I对于在angular 7中不使用rxjs时是否需要取消订阅感到困惑。如果需要取消订阅，那么如果不使用rxjs，我们如何才能取消订阅
// ts
export class ViewDataComponent implements OnInit {
regions: Region[];
dataSource: MatTableDataSource<PaginatedMapData>;
constructor(private
浏览 2提问于2019-08-06得票数 0
2回答
观察者可以使用Rx安全地监听多个可观察对象吗？
c#、system.reactive、observer-pattern、observable
我正在尝试了解如何使用Rx将多个可观测事件流式传输到一组事件中。但是当我运行下面的代码时，我得到了一个异常。因此，这是否意味着多个观察者总是容易因为违反Rx语法而出现异常？我的意思是，如果这些多个观察者中的两个偶然地同时产生一个事件(任何两个观察者都会有一定的概率同时产生)，它应该会给出一个异常。
DateTimeOffset start;
object sync = new object();
var subject = new Subject<long>();
var observer = Observer.Create<l
浏览 4提问于2011-12-14得票数 5
回答已采纳
4回答
如何防止调用函数调用正在被销毁的子类的实例
c++、multithreading
我不得不对一个很难找到的错误进行修复，但我对这个修复并不满意。我们的应用程序是在Windows中运行的C++，错误是一个纯粹的虚拟调用崩溃。下面是一些背景知识：
class Observable
{
public:
Observable();
virtual ~Observable();
void Attach(Observer&); // Seize lock, then add Observer to the list
void Detach(Observer&); // Seize lock, then remove Observer fr
浏览 0提问于2016-04-08得票数 2
2回答
RxJava的Observable.subscriber()的onNext回调必须使用线程安全对象吗？
rx-java、rx-java2
下面是我的代码：
ArrayList<T> result = new ArrayList<T>();
observable.subscribe(result::add, <something here>, <something here>);
这不是建议的做法吗？result应该是线程安全的结构吗？
浏览 0提问于2017-11-18得票数 0
2回答
RxJS:你怎么知道在使用Observable.create时需要清理哪些东西
javascript、rxjs、rxjs5
我正在努力获得一个更好的了解清理后，我创造了一个定制的可观察。为了避免内存泄漏，您应该使用一次性函数进行清理。在这种情况下，我使用的是Rx计时器方法，而不是setInterval。我认为，当我调用observer.onCompleted()时，在内部清理计时器，我的一次性操作是无用的。我对这个过程的理解是正确的吗？
function countInterval(interval, times) {
return Rx.Observable.create(function (observer) {
var timerId = Rx.Observable.timer(0, inte
浏览 7提问于2016-12-07得票数 2
回答已采纳
2回答
阻止对共享资源的并发更新
java、concurrency、observable
我有类P，类Q和类R相应地更新表Pt，表Qt和表Ri。类P可以从图形界面Pi修改，对于Qi和Ri也是如此。
现在，某些数据在类P、Q和R之间共享。
出于这个原因，我们想要贴近用户，每当Pi、Qi和Ri同时更新数据时，都会显示一条消息(在所有界面上)，屏幕变得冻结：“此数据正在从其他地方修改，请等待一段时间。”
我考虑在这里使用Observable模式，其中这些类P、Q和R在Observable上注册，而observable负责并发访问。这条路走对了吗？
浏览 1提问于2012-09-13得票数 0
3回答
玩家快速碰撞应用程序
ios、iphone、swift、avplayer、player-swift
我在我的项目中增加了播放视频的播放器-斯威夫特，但是当我弹出那个控制器应用程序时，它会与下面的日志崩溃。
由于NSRangeException异常而终止应用程序，原因是：“无法删除键路径的观察者”速率“，因为它没有注册为观察者。”
有人知道吗？我用过这个播放器
提前谢谢！
浏览 4提问于2017-09-05得票数 0
4回答
更新，客户端是否会在继续之前完成执行其java.util.Observable ()
java、observable
当我调用时：
setChanged();
notifyObservers();
在java.until.Observable类上，在java.until.Observable类继续运行之前，是否所有侦听的观察者对象都会完成其udpate()方法的执行-假设我们在同一个Thread线程中运行？
这一点很重要，因为我将在快速让步中通过notifyObservers(Object o)方法发送一些消息，重要的是每个观察者类都在新的方法之前完成了它的方法。
我知道当我们调用notifyObservers()时，每个观察者类的执行顺序可能会有所不同--重要的是每个单独实例的方法执行顺序是有顺序的。
浏览 0提问于2010-06-02得票数 4
回答已采纳
3回答
反应式框架Hello World
c#、.net、system.reactive、reactive-programming
这是。但我想尝试错误处理程序，将程序修改为：
var cookiePieces = Observable.Range(1, 10);
cookiePieces.Subscribe(x =>
{
Console.WriteLine("{0}! {0} pieces of cookie!", x);
throw new Exception(); // newly added by myself
},
ex => Console.WriteLine("the exception message..."),
浏览 2提问于2010-07-13得票数 3
回答已采纳
2回答
在Rxjs中，我知道subscribe方法在可观察的执行中有三种类型的值:next、error、complete.It。在subscribe()方法中编写箭头函数很容易，但我在某个地方遇到了subscribe({})方法，我不知道它在means.for示例中是什么：
var observable = Rx.Observable.create(function (observer) {
observer.next(1);
observer.next(2);
observer.next(3);
setTimeout(() => {
observer.next(4);
浏览 0提问于2016-11-09得票数 0
1回答
在处理数据之前，rxjs检查流是否为空
javascript、rxjs
我们有下面的小溪。
const recorders = imongo.listCollections('recorders')
.flatMapConcat(names => {
const recorders = names
.map(entry => entry.name)
.filter(entry => !_.contains(
['recorders.starts',
'recorders.
浏览 2提问于2016-09-26得票数 1
回答已采纳
1回答
如何在lambda和ObservableSource中使用concat
kotlin、rx-java2
RxJava2
kotlin
这个工作正常，我可以连接两个可观察到的。
Observable.concat(countries(), animals())
.subscribeBy {
println(it)
}
这是我无法理解的示例，因为它使用的lambda似乎采用了一个ObservableSource，并且我想要连接这两个可观测值，但是它会导致一个空异常。只是想知道我做错了什么。那么，使用带有凹板的lambda的目的是什么？
Observa
浏览 2提问于2020-03-20得票数 4
回答已采纳
2回答
RxJava的.debounce()干扰我观察到的线程和错误处理
android、multithreading、retrofit、rx-java、rx-android
我想在我的安卓应用程序中进行一个标准搜索，输入一个EditText，等待用户完成输入，然后使用Retrofit启动一个网络请求：
// make observable out of EditText
Observable<OnTextChangeEvent> textObs = WidgetObservable.text(searchText);
mSearchResultSubscription =
textObs
// wait until user has not typed for 350 milliseconds
.deboun
浏览 1提问于2015-07-15得票数 7
2回答
使用weak_ptr实现观察者模式
c++、c++11、observer-pattern、observers、weak-ptr
到目前为止，我所拥有的是：
Observer.h
class Observer
{
public:
~Observer();
virtual void Notify() = 0;
protected:
Observer();
};
class Observable
{
public:
~Observable();
void Subscribe( std::shared_ptr<Observer> observer );
void Unsubscribe( std::shared_ptr<Observer> observe
浏览 3提问于2016-09-16得票数 7
1回答
使用Java观察者时会发生线程死锁
java、multithreading、jakarta-ee、thread-safety、deadlock
在服务器端，我创建了一个名为事件提取器的非停止线程(无限循环使用In run方法)，它扩展了java可观察性。
当我调用notifyObservers方法时，它工作得很好。但在某种程度上，这条线已经被完全锁定了。
有没有人帮我解决这个问题。我已经分享了下面的代码
public class EventExtractor extends Observable implements Runnable {
@Override
public void run() {
while (true) {
try {
Thr
浏览 1提问于2013-12-13得票数 0
回答已采纳
1回答
在意外线程上可观察到的RxAndroid运行
android、rx-java、reactive-programming、rx-android
我正在尝试创建一个Observable，这样它就可以在某个时间间隔内从网络加载一些数据，并且每当用户刷新页面时都是如此。这是我到目前为止所掌握的要点：
PublishSubject<Long> refreshSubject = PublishSubject.create();
Observable<MyDataType> observable = Observable.merge(
Observable.interval(0, 3, TimeUnit.SECONDS),
refreshSubject
)
.flatMap(t -> {
//
浏览 4提问于2016-09-09得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
