Class: Rx::Subject::InnerSubscription

Inherits:
Object
  • Object
show all
Defined in:
lib/rx/subjects/subject.rb

Instance Method Summary collapse

Constructor Details

#initialize(subject, observer) ⇒ InnerSubscription

Returns a new instance of InnerSubscription.



105
106
107
108
 
# File 'lib/rx/subjects/subject.rb', line 105

def initialize(subject, observer)
  @subject = subject
  @observer = observer
end

Instance Method Details

#unsubscribe ⇒ Object 



110
111
112
113
114
115
116
 
# File 'lib/rx/subjects/subject.rb', line 110

def unsubscribe
  if @observer
    @subject.send(:unsubscribe_observer, @observer)
    @subject = nil
    @observer = nil
  end
end