Class: Mfp::OutgoingMessage

Inherits:

Object

• Object
• Mfp::OutgoingMessage

Defined in:

lib/mfp/outgoing_message.rb

Instance Attribute Summary

• #frame ⇒ Object readonly

  Returns the value of attribute frame.

Instance Method Summary

• #complete(error) ⇒ Object
• #initialize(frame) ⇒ OutgoingMessage constructor

  A new instance of OutgoingMessage.

• #wait ⇒ Object

Constructor Details

#initialize(frame) ⇒ OutgoingMessage

Returns a new instance of OutgoingMessage.

# File 'lib/mfp/outgoing_message.rb', line 7

def initialize(frame)
  @frame = frame
  @result = Async::Queue.new
end

Instance Attribute Details

#frame ⇒ Object (readonly)

Returns the value of attribute frame.

# File 'lib/mfp/outgoing_message.rb', line 5

def frame
  @frame
end

Instance Method Details

#complete(error) ⇒ Object

# File 'lib/mfp/outgoing_message.rb', line 13

def complete(error) = @result.enqueue(error)

#wait ⇒ Object

# File 'lib/mfp/outgoing_message.rb', line 12

def wait = @result.dequeue