// @flow

import type {Stream} from "@basic-streams/stream"

declare export default function takeUntil<T>(
  controller: Stream<any>,
  stream: Stream<T>,
): Stream<T>