Class: Temporalio::Internal::Worker::ActivityWorker::InboundImplementation

Inherits:

Worker::Interceptor::Activity::Inbound

• Object
• Worker::Interceptor::Activity::Inbound
• Temporalio::Internal::Worker::ActivityWorker::InboundImplementation

Defined in:

lib/temporalio/internal/worker/activity_worker.rb

Instance Attribute Summary

Attributes inherited from Worker::Interceptor::Activity::Inbound

#next_interceptor

Instance Method Summary

• #execute(input) ⇒ Object
• #init(outbound) ⇒ Object
• #initialize(worker) ⇒ InboundImplementation constructor

  A new instance of InboundImplementation.

Constructor Details

#initialize(worker) ⇒ InboundImplementation

# File 'lib/temporalio/internal/worker/activity_worker.rb', line 340

def initialize(worker)
  super(nil) # steep:ignore
  @worker = worker
end

Instance Method Details

#execute(input) ⇒ Object

# File 'lib/temporalio/internal/worker/activity_worker.rb', line 352

def execute(input)
  input.proc.call(*input.args)
end

#init(outbound) ⇒ Object

# File 'lib/temporalio/internal/worker/activity_worker.rb', line 345

def init(outbound)
  context = Activity::Context.current
  raise 'Unexpected context type' unless context.is_a?(RunningActivity)

  context._outbound_impl = outbound
end