JavaScript Academy · Lekcja

Strumienie transformujące

Proszę modyfikować dane przepływające przez potok.

Strumienie transformujące to bezpłatna lekcja JavaScript Academy na CoddyKit. To lekcja 3 z 4. Możesz przeczytać całą lekcję poniżej za darmo — a potem ćwiczyć ją interaktywnie w przeglądarce z wbudowanym edytorem kodu i tutorem AI dostępnym 24/7. To część ścieżki edukacyjnej JavaScript Academy, a Twój postęp synchronizuje się między webem a aplikacją CoddyKit. Kurs JavaScript Academy zawiera 4 lekcji w sumie.

Czym jest TransformStream

TransformStream znajduje się między stroną odczytu a stroną zapisu. Zapisywane fragmenty są przekształcane i emitowane na wyjściu — jest to etap potoku, który może dynamicznie mapować, filtrować lub zmieniać kształt danych.

Budowa

Ma dwa końce: writable (do którego trafiają dane) i readable (z którego wychodzą przekształcone dane).

const ts = new TransformStream();
console.log(ts.writable, ts.readable);

Metoda transform

Zachowanie należy zdefiniować za pomocą funkcji transform(chunk, controller). Do emitowania danych wyjściowych należy wywołać controller.enqueue().

const upper = new TransformStream({
  transform(chunk, controller) {
    controller.enqueue(chunk.toUpperCase());
  }
});

Jedno wejście, wiele wyjść

Transformacja może emitować zero, jeden lub kilka fragmentów dla każdego fragmentu wejściowego — doskonale nadaje się do dzielenia lub rozszerzania danych.

const splitter = new TransformStream({
  transform(line, controller) {
    for (const word of line.split(" ")) controller.enqueue(word);
  }
});

Filtrowanie za pomocą transformacji

Wystarczy nie dodawać do kolejki fragmentów, które mają zostać odrzucone.

const onlyEven = new TransformStream({
  transform(n, controller) {
    if (n % 2 === 0) controller.enqueue(n);
  }
});

Metoda flush

flush(controller) uruchamia się raz po zakończeniu danych wejściowych — idealnie nadaje się do wyemitowania pozostałości z bufora lub końcowego fragmentu.

const ts = new TransformStream({
  transform(c, ctrl) { ctrl.enqueue(c); },
  flush(ctrl) { ctrl.enqueue("[END]"); }
});

Buforowanie między fragmentami

Stan należy przechowywać w domknięciu, aby łączyć częściowe fragmenty, na przykład składać kompletne wiersze z danych podzielonych w dowolnych miejscach.

let buffer = "";
new TransformStream({
  transform(chunk, ctrl) {
    buffer += chunk;
    const parts = buffer.split("\n");
    buffer = parts.pop();
    for (const line of parts) ctrl.enqueue(line);
  },
  flush(ctrl) { if (buffer) ctrl.enqueue(buffer); }
});

Wbudowane strumienie transformacji

Platforma udostępnia TextDecoderStream, TextEncoderStream oraz CompressionStream/DecompressionStream — gotowe transformacje.

const gzip = new CompressionStream("gzip");
const compressed = inputStream.pipeThrough(gzip);

Łączenie za pomocą pipeThrough

readable.pipeThrough(transform) łączy źródło z transformacją i zwraca dane wyjściowe po stronie odczytu tej transformacji, gotowe do przekazania do następnego etapu.

const out = sourceStream
  .pipeThrough(new TextDecoderStream())
  .pipeThrough(upper);

Transformacje asynchroniczne

transform może być asynchroniczne — wewnątrz można używać await do wywoływania API lub wykonywania asynchronicznych operacji dla każdego fragmentu. Strumień czeka na rozstrzygnięcie obietnicy.

new TransformStream({
  async transform(chunk, ctrl) {
    const result = await process(chunk);
    ctrl.enqueue(result);
  }
});

Propagacja błędów

Rzucenie wyjątku wewnątrz transform powoduje błąd strumienia; odbiorcy znajdujący się dalej w potoku widzą błąd, a potok zostaje zamknięty.

new TransformStream({
  transform(chunk, ctrl) {
    if (!valid(chunk)) throw new Error("bad chunk");
    ctrl.enqueue(chunk);
  }
});

Szybki test

Proszę przetestować strumienie transformujące.

Podsumowanie: strumienie transformujące

Utworzyli Państwo transformacje za pomocą transform i flush, mapowali, filtrowali i rozwijali fragmenty, buforowali dane na granicach fragmentów, używali wbudowanych elementów, takich jak CompressionStream, oraz łączyli etapy za pomocą pipeThrough. Następny temat: backpressure i potoki.

Często zadawane pytania

Czy lekcja „Strumienie transformujące” jest bezpłatna?

Tak — pełny tekst „Strumienie transformujące” jest dostępny za darmo tutaj w sieci. Aby ćwiczyć ją interaktywnie (wbudowany edytor kodu i tutor AI dostępny 24/7) i odblokować resztę kursu JavaScript Academy, przejdź na CoddyKit PRO. Kurs JavaScript Academy zawiera 4 lekcji w sumie.

Co nauczysz się w „Strumienie transformujące”?

Proszę modyfikować dane przepływające przez potok. Ćwiczysz JavaScript Academy z praktycznym kodem, który uruchamiasz bezpośrednio w przeglądarce, a tutor AI dostępny 24/7 odpowiada na Twoje pytania podczas pracy nad lekcją.

Czy potrzebuję doświadczenia, aby zacząć JavaScript Academy?

Nie wymagamy żadnego doświadczenia. JavaScript Academy w CoddyKit jest strukturyzowany dla początkujących i zaawansowanych użytkowników, więc możesz zacząć tutaj lub od początku i uczyć się w swoim tempie. To lekcja 3 z 4.

Ile czasu zajmuje lekcja „Strumienie transformujące”?

Większość lekcji CoddyKit trwa około 5–10 minut. Każda lekcja to mały, interaktywny krok, dzięki czemu robisz systematyczne postępy i zawsze wracasz dokładnie do tego samego miejsca — na webie i w aplikacji.

Czy mogę pisać i uruchamiać kod w tej lekcji JavaScript Academy?

Tak. Każda lekcja JavaScript Academy zawiera wbudowany edytor kodu, więc piszesz i uruchamiasz prawdziwy kod bezpośrednio w przeglądarce i od razu otrzymujesz sprzężenie zwrotne od AI — bez konfiguracji na komputerze.

Wszystkie lekcje w tym kursie

← Powrót do JavaScript Academy