Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
Fix up combine talkback signals
+3
-3
+3
-3
src/operators.ts
+3
-3
src/operators.ts
···
81
81
}
82
82
} else if (signal.tag === SignalKind.Start) {
83
83
talkbackA = signal[0];
84
-
} else if (lastValB === undefined && !ended) {
84
+
} else if (lastValB === undefined) {
85
85
lastValA = signal[0];
86
86
if (!gotSignal) {
87
87
talkbackB(TalkbackKind.Pull);
···
104
104
}
105
105
} else if (signal.tag === SignalKind.Start) {
106
106
talkbackB = signal[0];
107
-
} else if (lastValA === undefined && !ended) {
107
+
} else if (lastValA === undefined) {
108
108
lastValB = signal[0];
109
109
if (!gotSignal) {
110
-
talkbackB(TalkbackKind.Pull);
110
+
talkbackA(TalkbackKind.Pull);
111
111
} else {
112
112
gotSignal = false;
113
113
}