class Rx::AsyncSubject::InnerSubscription
Public Class Methods
new(subject, observer)
click to toggle source
# File lib/rx/subjects/async_subject.rb, line 138 def initialize(subject, observer) @subject = subject @observer = observer end
Public Instance Methods
unsubscribe()
click to toggle source
# File lib/rx/subjects/async_subject.rb, line 143 def unsubscribe if @observer @subject.gate.synchronize do if !@subject.unsubscribed && @observer @subject.observers.delete @observer @observer = nil end end end end