Method: Rx::AutoDetachObserver#initialize

Defined in:
lib/rx/core/auto_detach_observer.rb

#initialize(observer) ⇒ AutoDetachObserver

Returns a new instance of AutoDetachObserver.



36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/rx/core/auto_detach_observer.rb', line 36

def initialize(observer)
  @observer = observer
  @m = SingleAssignmentSubscription.new

  config = ObserverConfiguration.new
  config.on_next(&method(:on_next_core))
  config.on_error(&method(:on_error_core))
  config.on_completed(&method(:on_completed_core))

  super(config)
end