               unsub = nop
       unsub = @subscribeInternal (event) ->
         if (event.hasValue())
-          if (initSent && event.isInitial())
+          if (initSent and event.isInitial())
             Bacon.more # init already sent, skip this one
           else
             sendInit() unless event.isInitial()

    Bacon.later(delay(context)).filter(false).concat(Bacon.once().flatMap(delayedRetry))

  withDescription(Bacon, "retry", options, source().flatMapError (e) ->
    if isRetryable(e) && retries > 0
      retry(error: e, retriesDone: maxRetries - retries)
    else
      Bacon.once(new Error(e)))

  new EventStream describe(Bacon, "fromArray", values), (sink) ->
    unsubd = false
    reply = Bacon.more
    while (reply != Bacon.noMore) and !unsubd
      if _.empty values
        sink(end())
        reply = Bacon.noMore
