implab/implabjs-djx Files · djx/src/main/ts/observable/SubscriptionImpl.ts

Added tag v1.10.3 for changeset

cin - - Load All Authors

File last commit:

r158:078eca3dc271 v1.10.3 default


                r159:0b327f31e28f

tip default

Download file

             SubscriptionImpl.ts
        
                    57 lines
            
             | 1.3 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / djx / src / main / ts / observable / SubscriptionImpl.ts
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import { ICancellation } from "@implab/core-amd/interfaces";

      export interface Subscription {

          finalize(): boolean;

          isClosed(): boolean;

          teardown(cleanup: void | (() => void)): void;

          around<T>(next: (item: T) => void): (item: T) => void;

          unsubscribe(): void;

      }

      const noop = () => {};

      export class SubscriptionImpl implements Subscription {    

          private _done = false;

          private _cleanup = noop;

          finalize() {

              return this._done ? false : ((0,this._cleanup)(), this._done = true);

          }

          isClosed() {

              return this._done;

          }

          teardown(cleanup: void | (() => void)) {

              if (cleanup) {

                  if (this._done) {

                      cleanup();

                  } else {

                      const _prev = this._cleanup;

                      this._cleanup = _prev === noop ? cleanup : () => (_prev(), cleanup());

                  }

              }

          }

          cancellable(ct: ICancellation, reject: (err: unknown) => void) {

              if (ct.isSupported()) {

                  const h = ct.register(reason => this.finalize() && reject(reason));

                  this.teardown(() => h.destroy());

              }

          }

          unsubscribe() {

              this.finalize();

          }

          around<T>(next: (item: T) => void): (item: T) => void {

              return (item) => this._done ? void(0) : next(item);

          }

      }

	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 } from "@implab/core-amd/interfaces";

				export interface Subscription {
				finalize(): boolean;

				isClosed(): boolean;

				teardown(cleanup: void \| (() => void)): void;

				around<T>(next: (item: T) => void): (item: T) => void;

				unsubscribe(): void;
				}

				const noop = () => {};


				export class SubscriptionImpl implements Subscription {

				private _done = false;

				private _cleanup = noop;

				finalize() {
				return this._done ? false : ((0,this._cleanup)(), this._done = true);
				}

				isClosed() {
				return this._done;
				}

				teardown(cleanup: void \| (() => void)) {
				if (cleanup) {
				if (this._done) {
				cleanup();
				} else {
				const _prev = this._cleanup;
				this._cleanup = _prev === noop ? cleanup : () => (_prev(), cleanup());
				}
				}
				}

				cancellable(ct: ICancellation, reject: (err: unknown) => void) {
				if (ct.isSupported()) {
				const h = ct.register(reason => this.finalize() && reject(reason));
				this.teardown(() => h.destroy());
				}
				}

				unsubscribe() {
				this.finalize();
				}

				around<T>(next: (item: T) => void): (item: T) => void {
				return (item) => this._done ? void(0) : next(item);
				}

				}