implab/implabjs-core Files · test/ts/ObservableTests.ts

working on Observable tests

cin - - Load All Authors

File last commit:

r24:70558f9420b3 propose observables


                r24:70558f9420b3

propose observables

Download file

             ObservableTests.ts
        
                    35 lines
            
             | 904 B
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / test / ts / ObservableTests.ts
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import { TraceSource, DebugLevel } from '@implab/core/log/TraceSource'

      import * as tape from 'tape';

      import { TapeWriter, delay } from './TestTraits';

      import { Observable } from '@implab/core/Observable';

      import { IObservable } from '@implab/core/interfaces';

      let trace = TraceSource.get("ObservableTests");

      tape('events sequence example', async t => {

          let events: IObservable<number>

          let done = new Promise<void>((resolve) => {

              events = new Observable<number>(async (notify, fail, complete) => {

                  for (let i = 0; i < 10; i++) {

                      await delay(0);

                      notify(i);

                  }

                  resolve();

              });

          });

          let count = 0;

          events.on(x => count = count + x);

          let first = await events.next();

          t.equals(first, 0, "the first event");

          await done;

          t.equals(count, 45, "the summ of the evetns");

          t.end();

      });

	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 { TraceSource, DebugLevel } from '@implab/core/log/TraceSource'
				import * as tape from 'tape';
				import { TapeWriter, delay } from './TestTraits';
				import { Observable } from '@implab/core/Observable';
				import { IObservable } from '@implab/core/interfaces';

				let trace = TraceSource.get("ObservableTests");

				tape('events sequence example', async t => {


				let events: IObservable<number>

				let done = new Promise<void>((resolve) => {
				events = new Observable<number>(async (notify, fail, complete) => {
				for (let i = 0; i < 10; i++) {
				await delay(0);
				notify(i);
				}
				resolve();
				});
				});

				let count = 0;
				events.on(x => count = count + x);

				let first = await events.next();

				t.equals(first, 0, "the first event");

				await done;

				t.equals(count, 45, "the summ of the evetns");

				t.end();
				});