Class: Rx::AsyncSubject::InnerSubscription

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

Instance Method Summary collapse

Constructor Details

#initialize(subject, observer) ⇒ InnerSubscription

Returns a new instance of InnerSubscription.



138
139
140
141
 
# File 'lib/rx/subjects/async_subject.rb', line 138

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

Instance Method Details

#unsubscribe ⇒ Object 



143
144
145
146
147
148
149
150
151
152
 
# 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