implab/implabjs-core Files · src/ts/components/Observable.ts

working on Observable

cin - - Load All Authors

File last commit:

r14:53e756f117f7 propose cancellat...


                r14:53e756f117f7

propose cancellat...

Download file

             Observable.ts
        
                    93 lines
            
             | 2.2 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / src / ts / components / Observable.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
working on Observable

              r14
            
      import { IObservable, IDestroyable, ICancellation } from '../interfaces';

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
      import { Cancellation } from '../Cancellation'

      import { argumentNotNull } from '../safe';

        cin
    
working on Observable

              r14
            
      interface Handler<T> {

          (x:T) : void

      }

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
        cin
    
working on Observable

              r14
            
      interface Initializer<T> {

          (notify: Handler<T>) : (() => void) | void;

      }

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
        cin
    
working on Observable

              r14
            
      class Observable<T> implements IObservable<T>, IDestroyable {

          private _once = new Array<Handler<T>>();

          private readonly _observers = new Array<Handler<T>>();

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
        cin
    
working on Observable

              r14
            
          private readonly _cleanup : (() => void) | void;

          constructor(func?: Initializer<T>) {

              this._cleanup = func && func(this._notify.bind(this));

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
          }

        cin
    
working on Observable

              r14
            
          on(observer: Handler<T>, error?: Handler<any>, complete?: () => void): IDestroyable {

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
              argumentNotNull(observer, "observer");

              this._observers.push(observer);

              let me = this;

              return {

                  destroy() {

                      me._removeObserver(observer);

                  }

              }

          }

        cin
    
working on Observable

              r14
            
          next(ct: ICancellation = Cancellation.none): Promise<T> {

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
              return new Promise<T>((resolve, reject) => {

                  this._once.push(resolve);

                  if (ct.isSupported()) {

                      ct.register((e) => {

                          this._removeOnce(resolve);

                          reject(e);

                      });

                  }

              });

          }

        cin
    
working on Observable

              r14
            
          destroy() {

              if(this._cleanup)

                  this._cleanup.call(null);

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
          }

        cin
    
working on Observable

              r14
            
          protected onObserverException(e: any) {

          }

          private _removeOnce(d: Handler<T>) {

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
              let i = this._once.indexOf(d);

              if (i >= 0)

                  this._once.splice(i);

          }

        cin
    
working on Observable

              r14
            
          private _removeObserver(d: Handler<T>) {

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
              let i = this._observers.indexOf(d);

              if (i >= 0)

                  this._observers.splice(i);

          }

        cin
    
working on Observable

              r14
            
          protected _notify(evt: T) {

              let guard = (observer: Handler<T>) => {

        cin
    
refactoring, all common interfaces placed to core/interfaces.ts...

              r13
            
                  try {

                      observer(evt);

                  } catch (e) {

                      this.onObserverException(e);

                  }

              }

              if (this._once.length) {

                  for (let i = 0; i < this._once.length; i++)

                      guard(this._once[i]);

                  this._once = [];

              }

              for (let i = 0; i < this._observers.length; i++)

                  guard(this._observers[i]);

          }

      }

      namespace Observable {

      }

      export = Observable;

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

cin working on Observable	r14	import { IObservable, IDestroyable, ICancellation } from '../interfaces';
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	import { Cancellation } from '../Cancellation'
		import { argumentNotNull } from '../safe';


cin working on Observable	r14	interface Handler<T> {
		(x:T) : void
		}
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13
cin working on Observable	r14	interface Initializer<T> {
		(notify: Handler<T>) : (() => void) \| void;
		}

cin refactoring, all common interfaces placed to core/interfaces.ts...	r13
cin working on Observable	r14	class Observable<T> implements IObservable<T>, IDestroyable {
		private _once = new Array<Handler<T>>();

		private readonly _observers = new Array<Handler<T>>();
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13
cin working on Observable	r14	private readonly _cleanup : (() => void) \| void;

		constructor(func?: Initializer<T>) {
		this._cleanup = func && func(this._notify.bind(this));
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	}

cin working on Observable	r14	on(observer: Handler<T>, error?: Handler<any>, complete?: () => void): IDestroyable {
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	argumentNotNull(observer, "observer");

		this._observers.push(observer);

		let me = this;
		return {
		destroy() {
		me._removeObserver(observer);
		}
		}
		}

cin working on Observable	r14	next(ct: ICancellation = Cancellation.none): Promise<T> {
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	return new Promise<T>((resolve, reject) => {
		this._once.push(resolve);
		if (ct.isSupported()) {
		ct.register((e) => {
		this._removeOnce(resolve);
		reject(e);
		});
		}
		});
		}

cin working on Observable	r14	destroy() {
		if(this._cleanup)
		this._cleanup.call(null);
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	}

cin working on Observable	r14	protected onObserverException(e: any) {
		}

		private _removeOnce(d: Handler<T>) {
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	let i = this._once.indexOf(d);
		if (i >= 0)
		this._once.splice(i);
		}

cin working on Observable	r14	private _removeObserver(d: Handler<T>) {
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	let i = this._observers.indexOf(d);
		if (i >= 0)
		this._observers.splice(i);
		}

cin working on Observable	r14	protected _notify(evt: T) {
		let guard = (observer: Handler<T>) => {
cin refactoring, all common interfaces placed to core/interfaces.ts...	r13	try {
		observer(evt);
		} catch (e) {
		this.onObserverException(e);
		}
		}

		if (this._once.length) {
		for (let i = 0; i < this._once.length; i++)
		guard(this._once[i]);
		this._once = [];
		}

		for (let i = 0; i < this._observers.length; i++)
		guard(this._observers[i]);
		}
		}

		namespace Observable {
		}

		export = Observable;