Node.js · Senior · Pytanie 23 z 75
Co daje generator asynchroniczny w pipeline?
await pipeline(
createReadStream("in.csv"),
async function* (source) {
for await (const chunk of source) yield transform(chunk);
},
createWriteStream("out.csv"),
);- 1Sposób na wykonanie transformacji w innym wątku
- ✓Poprawna odpowiedź: Krok transformacji zapisany jako zwykły kod asynchroniczny, a backpressure i błędami nadal zarządza
pipeline - 3Automatyczne równoległe przetwarzanie wszystkich kawałków
Wyjaśnienie
Generator pobiera kolejny kawałek dopiero, gdy zapis jest gotowy. Błąd gdziekolwiek niszczy wszystkie strumienie i odrzuca promise.