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