implab/implabjs-core Files · src/main/ts/CancellationAggregate.ts

wip migrating on new typescript build plugin

cin - - Load All Authors

File last commit:

r172:3969a8fb8049 release v1.4.6 default


                r174:b00d3153045c

default

Download file

             CancellationAggregate.ts
        
                    41 lines
            
             | 1.0 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / src / main / ts / CancellationAggregate.ts
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import { ICancellation, IDestroyable } from "./interfaces";

      export class CancellationAggregate implements ICancellation {

          private readonly _tokens: ICancellation[];

          constructor(tokens: ICancellation[]) {

              this._tokens = tokens || [];

          }

          throwIfRequested() {

              this._tokens.forEach(ct => ct.throwIfRequested());

          }

          isRequested() {

              return this._tokens.some(ct => ct.isRequested());

          }

          isSupported() {

              return !!this._tokens.length;

          }

          register(cb: (e: any) => void): IDestroyable {

              let fired = false;

              const once = (e: any) => {

                  if (!fired) {

                      fired = true;

                      destroy();

                      cb(e);

                  }

              };

              const destroy = () => subscriptions

                  .splice(0, subscriptions.length) // empty array

                  .forEach(subscription => subscription.destroy()); // cleanup

              const subscriptions = this._tokens.map(ct => ct.register(once));

              return {

                  destroy

              };

          }

      }

	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

				import { ICancellation, IDestroyable } from "./interfaces";

				export class CancellationAggregate implements ICancellation {
				private readonly _tokens: ICancellation[];

				constructor(tokens: ICancellation[]) {
				this._tokens = tokens \|\| [];
				}

				throwIfRequested() {
				this._tokens.forEach(ct => ct.throwIfRequested());
				}

				isRequested() {
				return this._tokens.some(ct => ct.isRequested());
				}
				isSupported() {
				return !!this._tokens.length;
				}
				register(cb: (e: any) => void): IDestroyable {
				let fired = false;

				const once = (e: any) => {
				if (!fired) {
				fired = true;
				destroy();
				cb(e);
				}
				};

				const destroy = () => subscriptions
				.splice(0, subscriptions.length) // empty array
				.forEach(subscription => subscription.destroy()); // cleanup

				const subscriptions = this._tokens.map(ct => ct.register(once));

				return {
				destroy
				};
				}
				}