Class: Temporalio::Worker::Interceptor::ActivityOutbound

Inherits:
Object
  • Object
show all
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.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(next_interceptor) ⇒ ActivityOutbound

Initialize outbound with the next interceptor in the chain.

Parameters:



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

def initialize(next_interceptor)
  @next_interceptor = next_interceptor
end

Instance Attribute Details

#next_interceptor ⇒ ActivityInbound (readonly)

Returns Next interceptor in the chain.

Returns:



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

def next_interceptor
  @next_interceptor
end

Instance Method Details

#heartbeat(input) ⇒ Object

Issue a heartbeat.

Parameters:



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

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