Class: Plumbing::Actor::Inline

Inherits:

Worker

• Object
• Literal::Data
• Worker
• Plumbing::Actor::Inline

Defined in:

lib/plumbing/actor/inline.rb

Defined Under Namespace

Classes: Message

Instance Method Summary

• #after ⇒ Object
• #call ⇒ Object
• #dispatch(message) ⇒ Object
• #message_class ⇒ Object
• #stop ⇒ Object

Methods inherited from Worker

#active?, #build_message, #cancel_deferred, #post

Instance Method Details

#after ⇒ Object

Raises:

• (Plumbing::Actor::NotSupported)

# File 'lib/plumbing/actor/inline.rb', line 11

def after(*, **) = raise Plumbing::Actor::NotSupported, "the inline worker cannot defer messages; use :async or :threaded"

#call ⇒ Object

# File 'lib/plumbing/actor/inline.rb', line 8

def call = nil

#dispatch(message) ⇒ Object

# File 'lib/plumbing/actor/inline.rb', line 13

def dispatch message
  message.deliver
end

#message_class ⇒ Object

# File 'lib/plumbing/actor/inline.rb', line 17

def message_class = Plumbing::Actor::Inline::Message

#stop ⇒ Object

# File 'lib/plumbing/actor/inline.rb', line 9

def stop = nil