Class: RFlow::ForwardToOutputPort

Inherits:
Connection show all
Defined in:
lib/rflow/connection.rb

Overview

Manually shuffle messages in-process from one output port to another output port. Can be used to get a Facade pattern effect - to have one component contain other components within it, shuttling messages in and out without making the internal component visible to the larger RFlow network.

Instance Attribute Summary

Attributes inherited from Connection

#config, #name, #options, #recv_callback, #uuid

Instance Method Summary collapse

Methods inherited from Connection

build, #connect_input!, #connect_output!, #input_port_key, #output_port_key

Constructor Details

#initialize(target_port) ⇒ ForwardToOutputPort

Returns a new instance of ForwardToOutputPort.



86
87
88
89
 
# File 'lib/rflow/connection.rb', line 86

def initialize(target_port)
  super(RFlow::Configuration::NullConnectionConfiguration.new)
  @target_port = target_port
end

Instance Method Details

#send_message(message) ⇒ Object 



91
92
93
 
# File 'lib/rflow/connection.rb', line 91

def send_message(message)
  @target_port.send_message(message)
end