Method: RxRuby::SingleAssignmentSubscription#initialize

Defined in:
lib/rx_ruby/subscriptions/single_assignment_subscription.rb

#initialize ⇒ SingleAssignmentSubscription

Returns a new instance of SingleAssignmentSubscription.



11
12
13
14
15
16
 
# File 'lib/rx_ruby/subscriptions/single_assignment_subscription.rb', line 11

def initialize
  @gate = Mutex.new() 
  @current = nil
  @unsubscribed = false
  @set = false
end