kitten.sh / wonka
Mirror: 🎩 A tiny but capable push & pull stream library for TypeScript and Flow
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

Fix incorrect queueing on concatMap

Phil Pluckthun 37238e1b 4fa19632

+1 -1
+1 -1
src/operators.ts
··· 149 149 if (innerActive) { 150 150 innerActive = false; 151 151 if (inputQueue.length) { 152 - applyInnerSource(map(inputQueue.pop()!)) 152 + applyInnerSource(map(inputQueue.shift()!)) 153 153 } else if (ended) { 154 154 sink(SignalKind.End); 155 155 } else if (!outerPulled) {