createWebSocketStream() — react Function Reference

Architecture documentation for the createWebSocketStream() function in index.js from the react codebase.

Function javascript BabelCompiler Entrypoint called by 2

Entity Profile

BabelCompiler→ Entrypoint→ createWebSocketStream() — react Function Reference

Dependency Diagram

graph TD
  d4550c74_c044_ca05_74c0_f2722e08bb76["createWebSocketStream()"]
  856b3a4c_6a24_b2e9_eb47_87b4757da255["index.js"]
  d4550c74_c044_ca05_74c0_f2722e08bb76 -->|defined in| 856b3a4c_6a24_b2e9_eb47_87b4757da255
  ed786118_418e_b032_130b_4222b0664687["callServer()"]
  ed786118_418e_b032_130b_4222b0664687 -->|calls| d4550c74_c044_ca05_74c0_f2722e08bb76
  1abc23ea_6ee8_cf9b_bb89_f6f01642f596["hydrateApp()"]
  1abc23ea_6ee8_cf9b_bb89_f6f01642f596 -->|calls| d4550c74_c044_ca05_74c0_f2722e08bb76
  style d4550c74_c044_ca05_74c0_f2722e08bb76 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

fixtures/flight/src/index.js lines 16–52

async function createWebSocketStream(url) {
  const ws = new WebSocket(url);
  ws.binaryType = 'arraybuffer';

  await new Promise((resolve, reject) => {
    ws.addEventListener('open', resolve, {once: true});
    ws.addEventListener('error', reject, {once: true});
  });

  const writable = new WritableStream({
    write(chunk) {
      ws.send(chunk);
    },
    close() {
      ws.close();
    },
    abort(reason) {
      ws.close(1000, reason && String(reason));
    },
  });

  const readable = new ReadableStream({
    start(controller) {
      ws.addEventListener('message', event => {
        controller.enqueue(event.data);
      });
      ws.addEventListener('close', () => {
        controller.close();
      });
      ws.addEventListener('error', err => {
        controller.error(err);
      });
    },
  });

  return {readable, writable};
}