ObservableTests.ts
73 lines
| 1.9 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r40 | 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"; | ||||
|
cin
|
r24 | |||
|
cin
|
r40 | const trace = TraceSource.get("ObservableTests"); | ||
|
cin
|
r24 | |||
|
cin
|
r40 | tape("events sequence example", async t => { | ||
|
cin
|
r24 | |||
|
cin
|
r40 | let events: IObservable<number>; | ||
|
cin
|
r24 | |||
|
cin
|
r40 | const done = new Promise<void>(resolve => { | ||
| events = new Observable<number>(async (notify, fail, finish) => { | ||||
|
cin
|
r24 | for (let i = 0; i < 10; i++) { | ||
| await delay(0); | ||||
| notify(i); | ||||
| } | ||||
|
cin
|
r40 | finish(); | ||
|
cin
|
r24 | resolve(); | ||
| }); | ||||
| }); | ||||
| let count = 0; | ||||
|
cin
|
r26 | let complete = false; | ||
| events.on(x => count = count + x, null, () => complete = true); | ||||
|
cin
|
r24 | |||
|
cin
|
r40 | const first = await events.next(); | ||
|
cin
|
r24 | |||
| t.equals(first, 0, "the first event"); | ||||
|
cin
|
r26 | t.false(complete, "the sequence is not complete"); | ||
|
cin
|
r24 | |||
| await done; | ||||
| t.equals(count, 45, "the summ of the evetns"); | ||||
|
cin
|
r26 | t.true(complete, "the sequence is complete"); | ||
| t.end(); | ||||
| }); | ||||
|
cin
|
r40 | tape("event sequence termination", async t => { | ||
| let events: IObservable<number>; | ||||
|
cin
|
r26 | |||
|
cin
|
r40 | const done = new Promise<void>(resolve => { | ||
|
cin
|
r26 | events = new Observable<number>(async (notify, fail, complete) => { | ||
| await delay(0); | ||||
| notify(1); | ||||
| complete(); | ||||
| notify(2); | ||||
| complete(); | ||||
| fail("Sequence terminated"); | ||||
| resolve(); | ||||
| }); | ||||
| }); | ||||
| let count = 0; | ||||
|
cin
|
r40 | events.on(() => {}, e => count++, () => count++); | ||
|
cin
|
r26 | |||
|
cin
|
r40 | const first = await events.next(); | ||
|
cin
|
r26 | t.equals(first, 1, "the first message"); | ||
| try { | ||||
| await events.next(); | ||||
| t.fail("shoud throw an exception"); | ||||
|
cin
|
r40 | } catch (e) { | ||
|
cin
|
r26 | t.pass("the sequence is terminated"); | ||
| } | ||||
| await done; | ||||
| t.equals(count, 1, "the sequence must be terminated once"); | ||||
|
cin
|
r24 | |||
| t.end(); | ||||
|
cin
|
r40 | }); | ||