class Rx::AnonymousObservable

Public Class Methods

new(&subscribe) click to toggle source
# File lib/rx/core/observable.rb, line 92
def initialize(&subscribe)
  @subscribe = subscribe
end

Protected Instance Methods

subscribe_core(obs) click to toggle source
# File lib/rx/core/observable.rb, line 98
def subscribe_core(obs)
  @subscribe.call(obs) || Subscription.empty
end