class Concurrent::Channel::Probe

def channel
  composite_value.nil? ? nil : composite_value[1]
end

def initialize(value = NO_VALUE, opts = {})
  super(value, opts)
end

def set_unless_assigned(value, channel)
  mutex.synchronize do
    return false if [:fulfilled, :rejected].include? @state
    set_state(true, [value, channel], nil)
    event.set
    true
  end
end

def value
  composite_value.nil? ? nil : composite_value[0]
end