Class: Temporalio::Worker::Interceptor::Activity::Outbound

Inherits:

Object

• Object
• Temporalio::Worker::Interceptor::Activity::Outbound

Defined in:

lib/temporalio/worker/interceptor.rb

Overview

Outbound interceptor for intercepting outbound activity calls. This should be extended by users needing to intercept activity calls.

Direct Known Subclasses

Internal::Worker::ActivityWorker::OutboundImplementation

Instance Attribute Summary

• #next_interceptor ⇒ Outbound readonly

  Next interceptor in the chain.

Instance Method Summary

• #heartbeat(input) ⇒ Object

  Issue a heartbeat.

• #initialize(next_interceptor) ⇒ Outbound constructor

  Initialize outbound with the next interceptor in the chain.

Constructor Details

#initialize(next_interceptor) ⇒ Outbound

Initialize outbound with the next interceptor in the chain.

Parameters:

• next_interceptor (Outbound) —

  Next interceptor in the chain.

# File 'lib/temporalio/worker/interceptor.rb', line 76

def initialize(next_interceptor)
  @next_interceptor = next_interceptor
end

Instance Attribute Details

#next_interceptor ⇒ Outbound (readonly)

Returns Next interceptor in the chain.

Returns:

• (Outbound) —

  Next interceptor in the chain.

# File 'lib/temporalio/worker/interceptor.rb', line 71

def next_interceptor
  @next_interceptor
end

Instance Method Details

#heartbeat(input) ⇒ Object

Issue a heartbeat.

Parameters:

• input (HeartbeatInput) —

  Input information.

# File 'lib/temporalio/worker/interceptor.rb', line 83

def heartbeat(input)
  @next_interceptor.heartbeat(input)
end