Class: WindUp::ForwardedCall

Inherits:

Celluloid::Call

• Object
• Celluloid::Call
• WindUp::ForwardedCall

Defined in:

lib/wind_up/calls.rb

Overview

WindUp’s ForwardedCall tells an actor to pull a message from a source mailbox when processed

Constant Summary

TIMEOUT =

Do not block if no work found

0

Instance Method Summary

• #dispatch(obj) ⇒ Object

  Pull the next message from the source, if available.

• #initialize(source) ⇒ ForwardedCall constructor

  A new instance of ForwardedCall.

Constructor Details

#initialize(source) ⇒ ForwardedCall

Returns a new instance of ForwardedCall.

# File 'lib/wind_up/calls.rb', line 9

def initialize(source)
  @source = source
end

Instance Method Details

#dispatch(obj) ⇒ Object

Pull the next message from the source, if available

# File 'lib/wind_up/calls.rb', line 14

def dispatch(obj)
  msg = @source.receive(TIMEOUT)
  ::Celluloid.mailbox << msg if msg
end