Class: OMQ::Ractor::ShareableConnection

Inherits:
SimpleDelegator
  • Object
show all
Includes:
TransparentDelegator
Defined in:
lib/omq/ractor.rb

Overview

Wraps an inproc Pipe with Ractor.make_shareable.

Instance Method Summary collapse

Methods included from TransparentDelegator

#is_a?

Instance Method Details

#send_message(obj) ⇒ void

This method returns an undefined value.

Parameters:

  • obj (Object)

    message to freeze and send via Ractor.make_shareable



131
132
133
# File 'lib/omq/ractor.rb', line 131

def send_message(obj)
  super(::Ractor.make_shareable(obj))
end