Class: Reactive::Observer

Inherits:

Object

• Object
• Reactive::Observer

Defined in:

lib/Reactive/observer.rb

Instance Method Summary

• #initialize(handlers) ⇒ Observer constructor

  A new instance of Observer.

• #on_complete ⇒ Object
• #on_error(error) ⇒ Object
• #on_next(value) ⇒ Object
• #unwrap ⇒ Object

Constructor Details

#initialize(handlers) ⇒ Observer

Returns a new instance of Observer.

# File 'lib/Reactive/observer.rb', line 4

def initialize(handlers)
  @handlers = handlers
end

Instance Method Details

#on_complete ⇒ Object

# File 'lib/Reactive/observer.rb', line 12

def on_complete
  @handlers[:on_complete].call()
end

#on_error(error) ⇒ Object

# File 'lib/Reactive/observer.rb', line 16

def on_error(error)
  @handlers[:on_error].call(error)
  unwrap
end

#on_next(value) ⇒ Object

# File 'lib/Reactive/observer.rb', line 8

def on_next(value)
  @handlers[:on_next].call(value)
end

#unwrap ⇒ Object

# File 'lib/Reactive/observer.rb', line 21

def unwrap
  @handlers = nil
end