     @subscribe = dispatcher.subscribe
     @subscribeInternal = @subscribe
     @hasSubscribers = dispatcher.hasSubscribers
+    registerObs(this)
   delay: (delay) ->
     @flatMap (value) ->
       Bacon.later delay, value

Bacon.repeatedly = (delay, values) ->
  index = 0
  Bacon.fromPoll(delay, -> values[index++ % values.length])

withMethodCallSupport = (wrapped) ->
  (f, args...) ->

      ->
        reply = Bacon.noMore
        unsub()
    registerObs(this)

  sample: (interval) =>
    @sampledBy Bacon.interval(interval, {})
