class Rx::ObserveOnObserver
Public Class Methods
new(scheduler, observer, cancel = nil)
click to toggle source
Calls superclass method
# File lib/rx/core/observe_on_observer.rb, line 17 def initialize(scheduler, observer, cancel = nil) @cancel = cancel super(scheduler, observer) end
Public Instance Methods
on_completed_core()
click to toggle source
Calls superclass method
# File lib/rx/core/observe_on_observer.rb, line 33 def on_completed_core ensure_active super end
on_error_core(error)
click to toggle source
Calls superclass method
# File lib/rx/core/observe_on_observer.rb, line 28 def on_error_core(error) ensure_active super(error) end
on_next_core(value)
click to toggle source
Calls superclass method
# File lib/rx/core/observe_on_observer.rb, line 23 def on_next_core(value) ensure_active super(value) end
unsubscribe()
click to toggle source
Calls superclass method
# File lib/rx/core/observe_on_observer.rb, line 38 def unsubscribe super cancel = nil Mutex.new.synchronize do cancel = @cancel @cancel = nil end canel.unsubscribe if cancel end