Module: Plumbing::Actor

Included in:

Pipe

Defined in:

lib/plumbing/actor.rb,
lib/plumbing/actor/async.rb,
lib/plumbing/actor/rails.rb,
lib/plumbing/actor/inline.rb,
lib/plumbing/actor/kernel.rb,
lib/plumbing/actor/threaded.rb,
lib/plumbing/actor/transporter.rb

Defined Under Namespace

Modules: ClassMethods Classes: Async, Inline, Rails, Threaded, Transporter

Class Method Summary

• .included(base) ⇒ Object
• .timeout ⇒ Object
• .transporter ⇒ Object

Instance Method Summary

• #in_context? ⇒ Boolean
• #safely ⇒ Object
• #stop ⇒ Object

Class Method Details

.included(base) ⇒ Object

# File 'lib/plumbing/actor.rb', line 15

def self.included base
  base.extend ClassMethods
end

.timeout ⇒ Object

# File 'lib/plumbing/actor/async.rb', line 48

def self.timeout
  Plumbing.config.timeout
end

.transporter ⇒ Object

# File 'lib/plumbing/actor/threaded.rb', line 78

def self.transporter
  @transporter ||= Plumbing::Actor::Transporter.new
end

Instance Method Details

#in_context? ⇒ Boolean

Returns:

• (Boolean)

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

def in_context? = proxy.in_context?

#safely ⇒ Object

# File 'lib/plumbing/actor.rb', line 6

def safely(&)
  proxy.safely(&)
  nil
end

#stop ⇒ Object

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

def stop = proxy.stop