implab/implabjs-djx Files · djx/src/main/ts/tsx/Scope.ts

added while, until methods to the observable interface....

added while, until methods to the observable interface. added stateful producer

cin - - Load All Authors

File last commit:

r118:e07418577cbc v1.6.1 default


                r124:fbe158a5752a

default

Download file

             Scope.ts
        
                    42 lines
            
             | 1.2 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / main / ts / tsx / Scope.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
Added Renderer, WatchRendition

              r94
            
      import { IDestroyable, IRemovable } from "@implab/core-amd/interfaces";

      import { isDestroyable, isRemovable } from "@implab/core-amd/safe";

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
      import { isUnsubscribable, Unsubscribable } from "../observable";

        cin
    
Added Renderer, WatchRendition

              r94
            
      export interface IScope {

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
          own(target: (() => void) | IDestroyable | IRemovable | Unsubscribable): void;

        cin
    
Added Renderer, WatchRendition

              r94
            
      }

      export class Scope implements IDestroyable, IScope {

          private readonly _cleanup: (() => void)[] = [];

          static readonly dummy: IScope = { own() { } };

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
          own(target: (() => void) | IDestroyable | IRemovable | Unsubscribable) {

        cin
    
Added Renderer, WatchRendition

              r94
            
              if (target instanceof Function) {

                  this._cleanup.push(target);

              } else if (isDestroyable(target)) {

                  this._cleanup.push(() => target.destroy());

              } else if (isRemovable(target)) {

                  this._cleanup.push(() => target.remove());

        cin
    
added whenRendered() method to wait for pending oprations to complete

              r118
            
              } else if (isUnsubscribable(target)) {

        cin
    
`Subscribable` is made compatible with rxjs, added map, filter and scan...

              r102
            
                  this._cleanup.push(() => target.unsubscribe());

        cin
    
Added Renderer, WatchRendition

              r94
            
              }

          }

          clean() {

              const guard = (cb: () => void) => {

                  try {

                      cb();

                  } catch {

                      // guard

                  }

        cin
    
linting

              r109
            
              };

        cin
    
Added Renderer, WatchRendition

              r94
            
              this._cleanup.forEach(guard);

              this._cleanup.length = 0;

          }

          destroy() {

              this.clean();

          }

      }

	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 Added Renderer, WatchRendition	r94	import { IDestroyable, IRemovable } from "@implab/core-amd/interfaces";
		import { isDestroyable, isRemovable } from "@implab/core-amd/safe";
cin added whenRendered() method to wait for pending oprations to complete	r118	import { isUnsubscribable, Unsubscribable } from "../observable";
cin Added Renderer, WatchRendition	r94
		export interface IScope {
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	own(target: (() => void) \| IDestroyable \| IRemovable \| Unsubscribable): void;
cin Added Renderer, WatchRendition	r94	}

		export class Scope implements IDestroyable, IScope {
		private readonly _cleanup: (() => void)[] = [];

		static readonly dummy: IScope = { own() { } };

cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	own(target: (() => void) \| IDestroyable \| IRemovable \| Unsubscribable) {
cin Added Renderer, WatchRendition	r94	if (target instanceof Function) {
		this._cleanup.push(target);
		} else if (isDestroyable(target)) {
		this._cleanup.push(() => target.destroy());
		} else if (isRemovable(target)) {
		this._cleanup.push(() => target.remove());
cin added whenRendered() method to wait for pending oprations to complete	r118	} else if (isUnsubscribable(target)) {
cin `Subscribable` is made compatible with rxjs, added map, filter and scan...	r102	this._cleanup.push(() => target.unsubscribe());
cin Added Renderer, WatchRendition	r94	}
		}

		clean() {
		const guard = (cb: () => void) => {
		try {
		cb();
		} catch {
		// guard
		}
cin linting	r109	};
cin Added Renderer, WatchRendition	r94
		this._cleanup.forEach(guard);
		this._cleanup.length = 0;
		}

		destroy() {
		this.clean();
		}

		}