Sha256: 129ec1df61ac0b66101fb4bf4ee5bfbe09977678881282785e410c65987d0b51
Contents?: true
Size: 1.59 KB
Versions: 2
Compression:
Stored size: 1.59 KB
Contents
module Trailblazer # This is DSL-independent code, focusing only on run-time. # # Developer's docs: https://trailblazer.to/2.1/docs/internals.html#internals-activity class Activity # include Activity::Interface # TODO def initialize(schema) @schema = schema end def call(args, **circuit_options) @schema[:circuit].( args, **circuit_options.merge(activity: self) ) end def to_h @schema.to_h end def inspect %(#<Trailblazer::Activity:0x#{object_id}>) end module Call # Canonical entry-point to invoke an {Activity} or Strategy such as {Activity::Railway} # with its taskWrap. def call(activity, ctx) TaskWrap.invoke(activity, [ctx, {}]) end end extend Call # {Activity.call}. end # Activity end require "trailblazer/activity/structures" require "trailblazer/activity/schema" require "trailblazer/activity/schema/implementation" require "trailblazer/activity/schema/intermediate" require "trailblazer/activity/circuit" require "trailblazer/activity/circuit/task_adapter" require "trailblazer/activity/introspect" require "trailblazer/activity/task_wrap/pipeline" require "trailblazer/activity/task_wrap/call_task" require "trailblazer/activity/task_wrap" require "trailblazer/activity/task_wrap/runner" require "trailblazer/activity/task_wrap/extension" require "trailblazer/activity/adds" require "trailblazer/activity/deprecate" require "trailblazer/activity/schema/compiler" require "trailblazer/activity/introspect/render" require "trailblazer/option" require "trailblazer/context"
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
trailblazer-activity-0.16.2 | lib/trailblazer/activity.rb |
trailblazer-activity-0.16.1 | lib/trailblazer/activity.rb |