observer.complete() 有什么作用？

Question

在rxjs中，在 observer.next() 之后，observer.complete() 到底做了什么？

Answer 1

从文件 observer.complete 通知的Observer是，可观察到已发送完基于推送的通知。

另一方面，observer.complete它是一个回调函数，并且Observable在它最后一次调用next()之后调用这个方法，如果它没有遇到任何错误。

Answer 2

在ReactiveX库中，有两种类型的消息。

第一个是普通消息。普通消息是随同发送的消息.next()，可以有 0 到多个。

第二种是通知。这些可以有两种类型——错误和成功。发送错误时会.error()附带一些错误详细信息（例如异常），发送成功则.complete()意味着故意不发送任何消息。每个可观察的结果都应该以一个错误或一个成功通知结束。