Class: MessageTransformer

Inherits:
Object
  • Object
show all
Includes:
Messenger
Defined in:
lib/socketeer/message_transformer.rb

Instance Attribute Summary

Attributes included from Messenger

#in_queue, #out_queue

Instance Method Summary collapse

Methods included from Messenger

#bind_queues

Constructor Details

#initialize(&transformer) ⇒ MessageTransformer

Returns a new instance of MessageTransformer.



10
11
12
 
# File 'lib/socketeer/message_transformer.rb', line 10

def initialize &transformer
  @transformer = transformer
end

Instance Method Details

#cycle ⇒ Object 



14
15
16
 
# File 'lib/socketeer/message_transformer.rb', line 14

def cycle
  handle_data_in pop_message
end

#handle_data_in(data) ⇒ Object 



18
19
20
21
 
# File 'lib/socketeer/message_transformer.rb', line 18

def handle_data_in data
  return if data.nil?
  push_message transform data
end