anchor.diff:  #endif
     val subscribeDuring: (Stream<'x> -> #Stream<'y>) -> IObservable<'x> -> Stream<'y>
   
  -  /// Preliminary and subject to change.
  +  /// Creates a stream that subscribes to the given observable for the duration
  +  /// of the job constructed with the stream.
     val subscribingTo: IObservable<'x> -> (Stream<'x> -> #Job<'y>) -> Job<'y>
   
  -  /// Returns observable that eagerly consumes the stream
  +  /// Returns an observable that eagerly consumes the given stream.
     val toObservable: Stream<'x> -> IObservable<'x>
   
     // Sequence combinators
  
positive.code:   /// `once xJ` is equivalent to `indefinitely xJ |> take 1`.
    val once: Job<'x> -> Stream<'x>
  
    /// Preliminary and subject to change.
    val unfoldJob: ('s -> #Job<option<'x * 's>>) -> 's -> Stream<'x>
    /// Preliminary and subject to change.
    val unfoldFun: ('s -> option<'x * 's>) -> 's -> Stream<'x>
  
    /// Preliminary and subject to change.
    val iterateJob: ('x -> #Job<'x>) -> 'x -> Stream<'x>
    /// Preliminary and subject to change.
    val iterateFun: ('x -> 'x) -> 'x -> Stream<'x>
  
    /// Creates an infinite stream of the given value.
  
negative.code: 
    /// Returns a stream that produces elements passed through the given job
    /// whenever the given streams produces elements.
  #if DOC
    ///
    /// Reference implementation:
    ///
  