Observable

模块

• esnext.observable
• esnext.symbol.observable

类型

class Observable {
  constructor(subscriber: SubscriberFunction);
  static of<T>(...items: Array<T>): SubscriptionObserver<T>;
  static from<T>(
    x: SubscriptionObserver<T> | Iterable<T>
  ): SubscriptionObserver<T>;
  static readonly [Symbol.species]: Observable;
  subscribe<T>(observer: Observer<T>): Subscription;
  subscribe<T>(
    onNext: (value: T) => void,
    onError?: (errorValue: Error) => void,
    onComplete?: () => void
  ): Subscription;
  [Symbol.observable](): this;
}

interface Subscription {
  unsubscribe(): void;
  get closed(): boolean;
}

interface Observer<T> {
  start(subscription: Subscription): void;
  next(value: T): void;
  error(errorValue: Error): void;
  complete(): void;
}

interface SubscriptionObserver<T> {
  next(value: T): void;
  error(errorValue: Error): void;
  complete(): void;
  get closed(): Boolean;
}

type SubscriberFunction = (observer: Observer) => (() => void) | Subscription;

interface SymbolConstructor {
  readonly observable: unique symbol;
}

入口点

core-js/proposals/observable
core-js(-pure)/full/observable
core-js(-pure)/full/symbol/observable

示例

示例:

new Observable((observer) => {
  observer.next("hello");
  observer.next("world");
  observer.complete();
}).subscribe({
  next(it) {
    console.log(it);
  },
  complete() {
    console.log("!");
  },
});