next: async()

in lib/AssistantStream.ts [150:167]

• 18 lines of code
• 4 McCabe index (conditional complexity)

      next: async (): Promise<IteratorResult<AssistantStreamEvent>> => {
        if (!pushQueue.length) {
          if (done) {
            return { value: undefined, done: true };
          }
          return new Promise<AssistantStreamEvent | undefined>((
            resolve,
            reject,
          ) => readQueue.push({ resolve, reject })).then((
            chunk,
          ) => (chunk
            ? { value: chunk, done: false }
            : { value: undefined, done: true })
          );
        }
        const chunk = pushQueue.shift()!;
        return { value: chunk, done: false };
      },