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