Function join

packages/core/src/flow/join.ts:43–77

(
  first: ThreadGenerator | boolean,
  ...tasks: ThreadGenerator[]
)

  ...tasks: ThreadGenerator[]
): ThreadGenerator;
export function* join(
  first: ThreadGenerator | boolean,
  ...tasks: ThreadGenerator[]
): ThreadGenerator {
  let all = true;
  if (typeof first === 'boolean') {
    all = first;
  } else {
    tasks.push(first);
  }

  const parent = useThread();
  const threads = <Thread[]>(
    tasks
      .map(task => parent.children.find(thread => thread.runner === task))
      .filter(thread => thread)
  );

  const startTime = parent.time();
  let childTime;
  if (all) {
    while (threads.find(thread => !thread.canceled)) {
      yield;
    }
    childTime = Math.max(...threads.map(thread => thread.time()));
  } else {
    while (!threads.find(thread => thread.canceled)) {
      yield;
    }
    const canceled = threads.filter(thread => thread.canceled);
    childTime = Math.min(...canceled.map(thread => thread.time()));
  }

  parent.time(Math.max(startTime, childTime));
}