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

Merged in propose observables (pull request #2)...

Merged in propose observables (pull request #2) Propose observables

cin - - Load All Authors

File last commit:

r26:0b0a30e050ba propose observables


                r29:e0b5fc764f84

default

Download file

             ObservableTests.ts
        
                    73 lines
            
             | 1.9 KiB
            
                | video/mp2t
            
             |
                TypeScriptLexer
            
             / test / ts / ObservableTests.ts
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        cin
    
working on Observable tests

              r24
            
      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);

                  }

        cin
    
the documentation on observables is added...

              r26
            
                  complete();

        cin
    
working on Observable tests

              r24
            
                  resolve();

              });

          });

          let count = 0;

        cin
    
the documentation on observables is added...

              r26
            
          let complete = false;

          events.on(x => count = count + x, null, () => complete = true);

        cin
    
working on Observable tests

              r24
            
          let first = await events.next();

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

        cin
    
the documentation on observables is added...

              r26
            
          t.false(complete, "the sequence is not complete");

        cin
    
working on Observable tests

              r24
            
          await done;

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

        cin
    
the documentation on observables is added...

              r26
            
          t.true(complete, "the sequence is complete");

          t.end();

      });

      tape('event sequence termination', async t => {

          let events: IObservable<number>

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

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

                  await delay(0);

                  notify(1);

                  complete();

                  notify(2);

                  complete();

                  fail("Sequence terminated");

                  resolve();

              });

          });

          let count = 0;

          events.on(() => {}, (e) => count++, () => count++);

          let first = await events.next();

          t.equals(first, 1, "the first message");

          try {

              await events.next();

              t.fail("shoud throw an exception");

          } catch(e) {

              t.pass("the sequence is terminated");

          }

          await done;

          t.equals(count, 1, "the sequence must be terminated once");

        cin
    
working on Observable tests

              r24
            
          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

cin working on Observable tests	r24	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);
		}
cin the documentation on observables is added...	r26	complete();
cin working on Observable tests	r24	resolve();
		});
		});

		let count = 0;
cin the documentation on observables is added...	r26	let complete = false;
		events.on(x => count = count + x, null, () => complete = true);
cin working on Observable tests	r24
		let first = await events.next();

		t.equals(first, 0, "the first event");
cin the documentation on observables is added...	r26	t.false(complete, "the sequence is not complete");
cin working on Observable tests	r24
		await done;

		t.equals(count, 45, "the summ of the evetns");
cin the documentation on observables is added...	r26	t.true(complete, "the sequence is complete");

		t.end();
		});

		tape('event sequence termination', async t => {
		let events: IObservable<number>

		let done = new Promise<void>((resolve) => {
		events = new Observable<number>(async (notify, fail, complete) => {
		await delay(0);
		notify(1);
		complete();
		notify(2);
		complete();
		fail("Sequence terminated");
		resolve();
		});
		});

		let count = 0;
		events.on(() => {}, (e) => count++, () => count++);

		let first = await events.next();
		t.equals(first, 1, "the first message");
		try {
		await events.next();
		t.fail("shoud throw an exception");
		} catch(e) {
		t.pass("the sequence is terminated");
		}

		await done;

		t.equals(count, 1, "the sequence must be terminated once");
cin working on Observable tests	r24
		t.end();
		});