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