class Rx::Subject::InnerSubscription

Public Class Methods

new(subject, observer) click to toggle source
# File lib/rx/subjects/subject.rb, line 105
def initialize(subject, observer)
  @subject = subject
  @observer = observer
end

Public Instance Methods

unsubscribe() click to toggle source
# File lib/rx/subjects/subject.rb, line 110
def unsubscribe
  if @observer
    @subject.send(:unsubscribe_observer, @observer)
    @subject = nil
    @observer = nil
  end
end