patch_turbo_cable_stream_source.js

const origDefine = customElements.define;
customElements.define = function(name, ctor, options) {
  if (name !== 'turbo-cable-stream-source') return origDefine.call(this, name, ctor, options);

  const proto = ctor.prototype;
  const origDisconnectedCallback = proto.disconnectedCallback;
  const origConnectedCallback = proto.connectedCallback;

  proto.connectedCallback = async function() {
    if (this.disconnecting) {
      this.disconnecting = false;
      return;
    }

    return await origConnectedCallback.apply(this);
  };

  proto.disconnectedCallback = async function() {
    // defer for one tick to allow the dom node to be re-attached, if turbo-permanent
    this.disconnecting = true;
    await new Promise(resolve => setTimeout(resolve, 0))
    if (!this.disconnecting) { return; }

    return origDisconnectedCallback.apply(this);
  };

  return origDefine.call(this, name, ctor, options);
};

// do this before importing turbo-rails