Class: Fluent::Counter::Future

Inherits:

Object

• Object
• Fluent::Counter::Future

Defined in:

lib/fluent/counter/client.rb

Defined Under Namespace

Classes: Result

Instance Method Summary

• #data ⇒ Object
• #errors ⇒ Object
• #errors? ⇒ Boolean
• #get ⇒ Object
• #initialize(loop, mutex) ⇒ Future constructor

  A new instance of Future.

• #set(v) ⇒ Object
• #wait ⇒ Object

Constructor Details

#initialize(loop, mutex) ⇒ Future

Returns a new instance of Future.

# File 'lib/fluent/counter/client.rb', line 247

def initialize(loop, mutex)
  @set = false
  @result = nil
  @mutex = mutex
  @loop = loop
end

Instance Method Details

#data ⇒ Object

# File 'lib/fluent/counter/client.rb', line 268

def data
  get.data
end

#errors ⇒ Object

# File 'lib/fluent/counter/client.rb', line 259

def errors
  get.errors
end

#errors? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/fluent/counter/client.rb', line 263

def errors?
  es = errors
  es && !es.empty?
end

#get ⇒ Object

# File 'lib/fluent/counter/client.rb', line 272

def get
  # Block until `set` method is called and @result is set
  join if @result.nil?
  @result
end

#set(v) ⇒ Object

# File 'lib/fluent/counter/client.rb', line 254

def set(v)
  @result = Result.new(v)
  @set = true
end

#wait ⇒ Object

# File 'lib/fluent/counter/client.rb', line 278

def wait
  res = get
  if res.error?
    Fluent::Counter.raise_error(res.errors.first)
  end
  res
end