async onMessageFromPython()

in tensorflow_similarity/visualization/projector_v2/lib/ipc.ts [89:125]

35 lines of code
5 McCabe index (conditional complexity)


  async onMessageFromPython(
    cellId: string,
    type: InboundMessageType,
    dataGlobalVarNames: string[],
    otherPayload: any
  ) {
    if (!this.rx) {
      throw new Error('');
    }
    const mainPayload = (await this.rx(dataGlobalVarNames)) ?? [];

    let message = null;
    switch (type) {
      case InboundMessageType.UPDATE: {
        message = {
          type,
          mainPayload,
          auxPayload: otherPayload,
        };
        break;
      }
      case InboundMessageType.METADATA: {
        message = {
          type,
          mainPayload,
          auxPayload: otherPayload,
        };
        break;
      }
      default:
        throw new RangeError(`Unknown message type: ${type}`);
    }

    if (message) {
      this.messengers.get(cellId).invokeCallbacks(message);
    }
  }