tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/scalar.ts


1
2
3
4
5
6
7
8
9
10
11

import { Observable } from '../Observable';

export function scalar<T>(value: T) {
  const result = new Observable<T>(subscriber => {
    subscriber.next(value);
    subscriber.complete();
  });
  result._isScalar = true;
  (result as any).value = value;
  return result;
}