W3cubDocs

/RxJS

GroupedObservable

class stable

An Observable representing values belonging to the same group represented by a common key. The values emitted by a GroupedObservable come from the source Observable. The common key is available as the field key on a GroupedObservable instance.

class GroupedObservable<K, T> extends Observable {
  constructor(key: K, groupSubject: Subject<T>, refCountSubscription?: RefCountSubscription)
  key: K
  _subscribe(subscriber: Subscriber<T>)

  // inherited from index/Observable
  static create: Function
  static if: typeof iif
  static throw: typeof throwError
  constructor(subscribe?: (this: Observable<T>, subscriber: Subscriber<T>) => TeardownLogic)
  _isScalar: boolean
  source: Observable<any>
  operator: Operator<any, T>
  lift<R>(operator: Operator<T, R>): Observable<R>
  subscribe(observerOrNext?: PartialObserver<T> | ((value: T) => void), error?: (error: any) => void, complete?: () => void): Subscription
  _trySubscribe(sink: Subscriber<T>): TeardownLogic
  forEach(next: (value: T) => void, promiseCtor?: PromiseConstructorLike): Promise<void>
  pipe(...operations: OperatorFunction<any, any>[]): Observable<any>
  toPromise(promiseCtor?: PromiseConstructorLike): Promise<T>
}

Constructor

constructor(key: K, groupSubject: Subject<T>, refCountSubscription?: RefCountSubscription)

Parameters

key

Type: K.

groupSubject

Type: Subject.

refCountSubscription

Optional. Default is undefined.

Type: RefCountSubscription.

Properties

Property Type Description
key K Declared in constructor.

Methods

_subscribe(subscriber: Subscriber<T>)

Parameters

subscriber

Type: Subscriber.

© 2015–2018 Google, Inc., Netflix, Inc., Microsoft Corp. and contributors.
Code licensed under an Apache-2.0 License. Documentation licensed under CC BY 4.0.
https://rxjs.dev/api/index/class/GroupedObservable