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