Home Manual Reference Source Test Repository 
import {Notification} from '@reactivex/rxjs/es6/Notification.js'
public class | source

Notification

代表可以被 Observable 发出的基于推送体系的事件或者值。对于像 materialize， dematerialize， observeOn 和其他管理通知的操作符来说，Notification 类尤其适用。 除了包装真正发出的值，它还使用元数据进行注解。例如，推送消息的类型是（next，error， or complete）。

See:

Test:

Static Method Summary

Static Public Methods
public static

创建类型为 complete 的 Notification 实例的快捷方法。
public static

createError(err: any): Notification<T>

使用给定的错误对象创建类型为 error 的 Notification 实例的快捷方法。
public static

createNext(value: T): Notification<T>

使用给定的值创建类型为 next 的 Notification 实例的快捷方法。

Method Summary

Public Methods
public

accept(nextOrObserver: Observer | function(value: T): void, error: function(err: any): void, complete: function(): void): any

接受一个 Observer 或者它的回调函数，然后相应地调用 observe 或者 do 方法。
public

do(next: function(value: T): void, error: function(err: any): void, complete: function(): void): any

给定一些 Observer 的回调函数， 将当前 Notification 所表示的值正确的传递给相应的回调函数。
public

observe(observer: Observer): *

将由 Notification 包装过的值传递给给定的 observer。
public

toObservable(): any

返回的 Observable 只传递代表当前 Notification 实例的通知。

Static Public Methods

public static createComplete(): Notification<any> source

创建类型为 complete 的 Notification 实例的快捷方法。

Return:

Notification<any>

没有值的complete型的通知。

public static createError(err: any): Notification<T> source

使用给定的错误对象创建类型为 error 的 Notification 实例的快捷方法。

Params:

NameTypeAttributeDescription
err any
  • optional

error 错误。

Return:

Notification<T>

代表传入错误的error型通知实例。

public static createNext(value: T): Notification<T> source

使用给定的值创建类型为 next 的 Notification 实例的快捷方法。

Params:

NameTypeAttributeDescription
value T

next 的值。

Return:

Notification<T>

代表传入值的next型通知实例。

Public Methods

public accept(nextOrObserver: Observer | function(value: T): void, error: function(err: any): void, complete: function(): void): any source

接受一个 Observer 或者它的回调函数，然后相应地调用 observe 或者 do 方法。

Params:

NameTypeAttributeDescription
nextOrObserver Observer | function(value: T): void

Observer 或者 next 回调函数。
error function(err: any): void
  • optional

Observer 的 error 回调函数。
complete function(): void
  • optional

Observer 的 complete 回调函数。

Return:

any

public do(next: function(value: T): void, error: function(err: any): void, complete: function(): void): any source

给定一些 Observer 的回调函数， 将当前 Notification 所表示的值正确的传递给相应的回调函数。

Params:

NameTypeAttributeDescription
next function(value: T): void

Observer 的 next 回调函数。
error function(err: any): void
  • optional

Observer 的 error 回调函数。
complete function(): void
  • optional

An Observer 的 complete 回调函数。

Return:

any

Test:

public observe(observer: Observer): * source

将由 Notification 包装过的值传递给给定的 observer。

Params:

NameTypeAttributeDescription
observer Observer

Return:

*

public toObservable(): any source

返回的 Observable 只传递代表当前 Notification 实例的通知。

Return:

any