push.rocks/smartrx
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz
2022-01-24 03:44:13 +01:00
parent 5f7580b28f
commit 5fdd756672
7 changed files with 19769 additions and 3987 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/test.observableintake.ts
View File

@ -4,12 +4,12 @@ import * as smartrx from '../ts/index';
tap.test('should create a valid instance of observableinstake', async () => {
const testObservableIntake = new smartrx.ObservableIntake();
expect(testObservableIntake).to.be.instanceOf(smartrx.ObservableIntake);
expect(testObservableIntake).toBeInstanceOf(smartrx.ObservableIntake);
});
tap.test('expect testObserservableIntake to push things', async (tools) => {
const testObserservableIntake = new smartrx.ObservableIntake();
testObserservableIntake.subscribe((value) => {
testObserservableIntake.subscribe((value: any) => {
console.log(value);
});
@ -25,7 +25,7 @@ tap.test('expect testObserservableIntake to push things', async (tools) => {
testObserservableIntake.push('wow');
testObserservableIntake.makeBuffered();
testObserservableIntake.push('jo');
testObserservableIntake.subscribe((value) => {
testObserservableIntake.subscribe((value: any) => {
console.log(value);
testObserservableIntake.signalComplete();
});

6
test/test.observablemap.ts
View File

@ -15,7 +15,7 @@ let testEmitter: events.EventEmitter;
tap.test('should create an instance', async () => {
testObservablemap = new smartrx.Observablemap();
expect(testObservablemap).be.instanceof(smartrx.Observablemap);
expect(testObservablemap).toBeInstanceOf(smartrx.Observablemap);
});
tap.test('should accept a new emitter', async () => {
@ -27,8 +27,8 @@ tap.test('should accept a new emitter', async () => {
});
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2');
expect(testObservable1 === testObservable2).to.be.true;
expect(testObservable1 === testObservable3).to.be.false;
expect(testObservable1 === testObservable2).toBeTrue();
expect(testObservable1 === testObservable3).toBeFalse();
testEmitter.emit('event1');
await done.promise;
});