Class: Rx::BehaviorSubject::InnerSubscription

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

Instance Method Summary collapse

Constructor Details

#initialize(subject, observer) ⇒ InnerSubscription

Returns a new instance of InnerSubscription.



125
126
127
128
 
# File 'lib/rx/subjects/behavior_subject.rb', line 125

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

Instance Method Details

#unsubscribe ⇒ Object 



130
131
132
133
134
135
136
137
138
139
 
# File 'lib/rx/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