Class: Rx::RefCountSubscription::InnerSubscription

Inherits:

Object

Object
Rx::RefCountSubscription::InnerSubscription

Defined in:: lib/rx/subscriptions/ref_count_subscription.rb

Instance Method Summary collapse

#initialize(parent) ⇒ InnerSubscription constructor

A new instance of InnerSubscription.
#unsubscribe ⇒ Object

Constructor Details

#initialize(parent) ⇒ `InnerSubscription`

Returns a new instance of InnerSubscription.



73
74
75

# File 'lib/rx/subscriptions/ref_count_subscription.rb', line 73

def initialize(parent)
  @parent = parent
end

Instance Method Details

#unsubscribe ⇒ `Object`

# File 'lib/rx/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