class RxRuby::BehaviorSubject::InnerSubscription
Public Class Methods
new(subject, observer)
click to toggle source
# File lib/rx_ruby/subjects/behavior_subject.rb, line 125 def initialize(subject, observer) @subject = subject @observer = observer end
Public Instance Methods
unsubscribe()
click to toggle source
# File lib/rx_ruby/subjects/behavior_subject.rb, line 130 def unsubscribe if @observer @subject.gate.synchronize do if !@subject.unsubscribed && @observer @subject.observers.delete @observer @observer = nil end end end end