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

more tests

cin - - Load All Authors

File last commit:

r77:04efbdad7679 default


                r77:04efbdad7679

default

Download file

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

        cin
    
tests moved under src/ folder...

              r50
            
      import { TraceSource, DebugLevel } from "@implab/core/log/TraceSource";

      import * as tape from "tape";

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

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

        cin
    
more tests

              r77
            
      import { delay } from "@implab/core/safe";

        cin
    
tests moved under src/ folder...

              r50
            
      const trace = TraceSource.get("ObservableTests");

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

          let events: IObservable<number>;

          const done = new Promise<void>(resolve => {

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

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

                      await delay(0);

                      notify(i);

                  }

                  finish();

                  resolve();

              });

          });

          let count = 0;

          let complete = false;

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

          const first = await events.next();

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

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

          await done;

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

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

          t.end();

      });

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

          let events: IObservable<number>;

          const 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++);

          const 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");

          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 tests moved under src/ folder...	r50	import { TraceSource, DebugLevel } from "@implab/core/log/TraceSource";
		import * as tape from "tape";
		import { Observable } from "@implab/core/Observable";
		import { IObservable } from "@implab/core/interfaces";
cin more tests	r77	import { delay } from "@implab/core/safe";
cin tests moved under src/ folder...	r50
		const trace = TraceSource.get("ObservableTests");

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

		let events: IObservable<number>;

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

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

		const first = await events.next();

		t.equals(first, 0, "the first event");
		t.false(complete, "the sequence is not complete");

		await done;

		t.equals(count, 45, "the summ of the evetns");
		t.true(complete, "the sequence is complete");

		t.end();
		});

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

		const 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++);

		const 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");

		t.end();
		});