Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
Fix up passesActivePush spec test
+5
-2
+5
-2
src/operators.test.ts
+5
-2
src/operators.test.ts
···
61
61
) => {
62
62
it('responds to eager Push signals (spec)', () => {
63
63
const values: any[] = [];
64
+
let talkback: TalkbackFn | null = null;
64
65
let sink: Sink<any> | null = null;
65
66
let pulls = 0;
66
67
67
68
const source: Source<any> = (_sink) => {
68
-
sink = _sink;
69
-
sink(start((signal) => {
69
+
(sink = _sink)(start((signal) => {
70
70
if (signal === TalkbackKind.Pull)
71
71
pulls++;
72
72
}));
···
76
76
expect(signal).not.toBe(SignalKind.End);
77
77
if (signal === SignalKind.End) {
78
78
/*noop*/
79
+
} else if (signal.tag === SignalKind.Start) {
80
+
talkback = signal[0];
79
81
} else if (signal.tag === SignalKind.Push) {
80
82
values.push(signal[0]);
83
+
talkback!(TalkbackKind.Pull);
81
84
}
82
85
});
83
86