Function onSuccess

packages/socket.io-cluster-engine/lib/engine.ts:416–425

(senderId: NodeId)

      const lockType = req.method === "GET" ? "read" : "write";

      const onSuccess = async (senderId: NodeId) => {
        if (upgrade) {
          req[kSenderId] = senderId;
          fn();
        } else {
          const transport = this.createTransport(transportName as any, req);
          this._hookTransport(sid, transport, lockType, senderId);
          transport.onRequest(req);
        }
      };

      this._acquireLock(sid, transportName, lockType, onSuccess, () =>
        fn(errorCode, errorContext),