INNER CODE UNIT · TypeScript

channel

xiangsx/gpt4free-ts · model/airops/index.ts:397

      const channel = child.setMsgListener((event, data) => {
        if (event !== 'agent-response') {
          return;
        }
        const { token, stream_finished } = parseJSON<{
          token: string;
          stream_finished: boolean;
        }>(data, {
          token: '',
          stream_finished: false,
        });
        if (stream_finished) {
          stream.write(Event.done, { content: '' });
          stream.end();
          this.logger.info('recv msg ok');
          return;
        }
        stream.write(Event.message, { content: token });

View source record →