class RxRuby::ObserveOnObserver

Public Class Methods

new(scheduler, observer, cancel = nil) click to toggle source
Calls superclass method
# File lib/rx_ruby/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_ruby/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_ruby/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_ruby/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_ruby/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