class Temporalio::Internal::Worker::ActivityWorker::InboundImplementation

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

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

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