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.



37
38
39
40
41
42
43
44
45
 
# File 'lib/fiber_stream/errors.rb', line 37

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.



35
36
37
 
# File 'lib/fiber_stream/errors.rb', line 35

def cause_class_name
  @cause_class_name
end

#cause_message ⇒ Object (readonly)

Returns the value of attribute cause_message.



35
36
37
 
# File 'lib/fiber_stream/errors.rb', line 35

def cause_message
  @cause_message
end

#kind ⇒ Object (readonly)

Returns the value of attribute kind.



35
36
37
 
# File 'lib/fiber_stream/errors.rb', line 35

def kind
  @kind
end

#original_cause ⇒ Object (readonly)

Returns the value of attribute original_cause.



35
36
37
 
# File 'lib/fiber_stream/errors.rb', line 35

def original_cause
  @original_cause
end

#sequence ⇒ Object (readonly)

Returns the value of attribute sequence.



35
36
37
 
# File 'lib/fiber_stream/errors.rb', line 35

def sequence
  @sequence
end