class RxRuby::RefCountSubscription::InnerSubscription

Public Class Methods

new(parent) click to toggle source
# File lib/rx_ruby/subscriptions/ref_count_subscription.rb, line 73
def initialize(parent)
  @parent = parent
end

Public Instance Methods

unsubscribe() click to toggle source
# File lib/rx_ruby/subscriptions/ref_count_subscription.rb, line 77
def unsubscribe
  parent = nil
  Mutex.new.synchronize do
    parent = @parent
    @parent = nil
  end
  parent.release if parent
end