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