WritableStream

deezer-web-streams-2.js

const source = new ReadableStream({…}); // As seen above
const destination = new WritableStream({
  start(controller) {
    // Return a promise to signal the construction is asynchronous
    return new Promise(resolve => {
      const source = new MediaSource();

      // Mark the WritableStream as ready when the source is open
      source.addEventListener('sourceopen', () => {
        this.buffer = source.addSourceBuffer('audio/mpeg');
        resolve();
      });

      player.src = URL.createObjectURL(source);
    });
  },

  write(chunk, controller) {
    // When receiving a chunk append it to the player's buffer
    this.buffer.appendBuffer(chunk);
  }
});

source.pipeTo(destination);