Module: Plumbing

Defined in:
lib/plumbing.rb,
lib/plumbing/actor.rb,
lib/plumbing/event.rb,
lib/plumbing/types.rb,
lib/plumbing/version.rb,
lib/plumbing/pipeline.rb,
lib/plumbing/provider.rb,
lib/plumbing/operation.rb,
lib/plumbing/observable.rb,
lib/plumbing/actor/async.rb,
lib/plumbing/actor/rails.rb,
lib/plumbing/actor/inline.rb,
lib/plumbing/actor/worker.rb,
lib/plumbing/actor/message.rb,
lib/plumbing/operation/dsl.rb,
lib/plumbing/pipeline/base.rb,
lib/plumbing/pipeline/only.rb,
lib/plumbing/actor/deferral.rb,
lib/plumbing/actor/threaded.rb,
lib/plumbing/operation/state.rb,
lib/plumbing/pipeline/except.rb,
lib/plumbing/pipeline/filter.rb,
lib/plumbing/pipeline/source.rb,
lib/plumbing/provider/router.rb,
lib/plumbing/operation/errors.rb,
lib/plumbing/operation/events.rb,
lib/plumbing/actor/definitions.rb,
lib/plumbing/operation/mermaid.rb,
lib/plumbing/pipeline/junction.rb,
lib/plumbing/actor/configuration.rb,
lib/plumbing/operation/generator.rb,
lib/plumbing/operation/transition.rb,
lib/plumbing/operation/wait_options.rb

Defined Under Namespace

Modules: Actor, Awaitable, Observable Classes: Error, Event, Operation, Pipeline, Provider

Constant Summary collapse

VERSION = 
"1.0.0"

Class Method Summary collapse

Class Method Details

.OneOf(*values) ⇒ Object

A literal-compatible predicate matching any of the given values. Primary use: as the type passed to a Literal prop (e.g. Message#status).



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

def self.OneOf(*values) = proc { |v| values.include? v }

.services ⇒ Object 



161
162
163
 
# File 'lib/plumbing/provider.rb', line 161

def self.services
  @services ||= Provider.new
end