class Rx::Subject::AnonymousSubject
Public Class Methods
new(observer, observable)
click to toggle source
# File lib/rx/subjects/subject_extensions.rb, line 20 def initialize(observer, observable) @observer = observer @observable = observable end
Public Instance Methods
on_completed()
click to toggle source
# File lib/rx/subjects/subject_extensions.rb, line 25 def on_completed @observer.on_completed end
on_error(error)
click to toggle source
# File lib/rx/subjects/subject_extensions.rb, line 29 def on_error(error) raise 'error cannot be nil' unless error @observer.on_error(error) end
on_next(value)
click to toggle source
# File lib/rx/subjects/subject_extensions.rb, line 34 def on_next(value) @observer.on_next(value) end
subscribe(observer)
click to toggle source
# File lib/rx/subjects/subject_extensions.rb, line 38 def subscribe(observer) raise 'observer cannot be nil' unless observer @observable.subscribe(observer) end