Subject.d.ts 358 B

123456789
  1. import { IStreamResult, IStreamSubscriber, ISubscription } from "./Stream";
  2. /** Stream implementation to stream items to the server. */
  3. export declare class Subject<T> implements IStreamResult<T> {
  4. constructor();
  5. next(item: T): void;
  6. error(err: any): void;
  7. complete(): void;
  8. subscribe(observer: IStreamSubscriber<T>): ISubscription<T>;
  9. }