Exception: FiberStream::RactorMapError

Inherits:
RuntimeError
  • Object
show all
Defined in:
lib/fiber_stream/errors.rb

Overview

Normalized failure raised for Ractor-backed mapping errors.

Worker exceptions and Ractor transfer failures may not be directly transferable back to the main ractor. This error preserves the ordered input sequence, failure kind, and original exception class/message metadata.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(sequence:, kind:, cause_class_name:, cause_message:, cause: nil) ⇒ RactorMapError

Returns a new instance of RactorMapError.



34
35
36
37
38
39
40
41
42
 
# File 'lib/fiber_stream/errors.rb', line 34

def initialize(sequence:, kind:, cause_class_name:, cause_message:, cause: nil)
  @sequence = sequence
  @kind = kind
  @cause_class_name = cause_class_name
  @cause_message = cause_message
  @original_cause = cause

  super("ractor_map #{kind} failure at sequence #{sequence}: #{cause_class_name}: #{cause_message}")
end

Instance Attribute Details

#cause_class_name ⇒ Object (readonly)

Returns the value of attribute cause_class_name.



32
33
34
 
# File 'lib/fiber_stream/errors.rb', line 32

def cause_class_name
  @cause_class_name
end

#cause_message ⇒ Object (readonly)

Returns the value of attribute cause_message.



32
33
34
 
# File 'lib/fiber_stream/errors.rb', line 32

def cause_message
  @cause_message
end

#kind ⇒ Object (readonly)

Returns the value of attribute kind.



32
33
34
 
# File 'lib/fiber_stream/errors.rb', line 32

def kind
  @kind
end

#original_cause ⇒ Object (readonly)

Returns the value of attribute original_cause.



32
33
34
 
# File 'lib/fiber_stream/errors.rb', line 32

def original_cause
  @original_cause
end

#sequence ⇒ Object (readonly)

Returns the value of attribute sequence.



32
33
34
 
# File 'lib/fiber_stream/errors.rb', line 32

def sequence
  @sequence
end