+2 -2

src/operators.ts

reviewed

··· 230 230 let talkback = talkbackPlaceholder; 231 231 source(signal => { 232 232 if (signal === SignalKind.End) { 233 233 - sink(signal); 233 233 + sink(SignalKind.End); 234 234 } else if (signal.tag === SignalKind.Start) { 235 235 talkback = signal[0]; 236 236 sink(signal); ··· 309 309 ended = true; 310 310 outerTalkback(TalkbackKind.Close); 311 311 } 312 312 - while (innerTalkbacks.length) innerTalkbacks.pop()!(TalkbackKind.Close); 312 312 + while (innerTalkbacks.length) innerTalkbacks.shift()!(TalkbackKind.Close); 313 313 } else { 314 314 if (!ended && !outerPulled) { 315 315 outerPulled = true;

+1 -1

src/sinks.ts

reviewed

··· 47 47 ended = true; 48 48 } else if (signal.tag === SignalKind.Start) { 49 49 (talkback = signal[0])(TalkbackKind.Pull); 50 50 - } else if (!ended) { 50 50 + } else { 51 51 values.push(signal[0]); 52 52 talkback(TalkbackKind.Pull); 53 53 }

+1 -3

src/sources.ts

reviewed

··· 14 14 } else if (looping) { 15 15 pulled = true; 16 16 } else { 17 17 - pulled = true; 18 18 - looping = true; 19 17 for (pulled = looping = true; pulled && !ended; current++) { 20 18 if (current < array.length) { 21 19 pulled = false; ··· 58 56 }, 59 57 complete() { 60 58 if (!ended) { 61 61 - ended = false; 59 59 + ended = true; 62 60 sink(SignalKind.End); 63 61 } 64 62 },