Function publish

packages/socket.io-adapter/lib/cluster-adapter.ts:675–683

(
    message: DistributiveOmit<ClusterMessage, "nsp" | "uid">,
  )

  }

  protected publish(
    message: DistributiveOmit<ClusterMessage, "nsp" | "uid">,
  ): void {
    debug("[%s] sending message %s", this.uid, message.type);

    this.publishAndReturnOffset(message).catch((err) => {
      debug("[%s] error while publishing message: %s", this.uid, err);
    });
  }

  protected publishAndReturnOffset(
    message: DistributiveOmit<ClusterMessage, "nsp" | "uid">,