module TCPSumac
Public Class Methods
accept(duck_types: {}, entry: nil, entry_class: nil, max_message_length: Float::INFINITY, port: , workers: 1)
click to toggle source
# File lib/tcp_sumac.rb, line 25 def self.accept(duck_types: {}, entry: nil, entry_class: nil, max_message_length: Float::INFINITY, port: , workers: 1) server = listen(duck_types: duck_types, entry: entry, entry_class: entry_class, max_message_length: max_message_length, port: port, workers: workers) sumac = server.accept server.close sumac end
connect(duck_types: {}, entry: nil, host: , max_message_length: Float::INFINITY, port: , workers: 1)
click to toggle source
# File lib/tcp_sumac.rb, line 14 def self.connect(duck_types: {}, entry: nil, host: , max_message_length: Float::INFINITY, port: , workers: 1) messenger = TCPMessenger.connect(duck_types: duck_types, host: host, max_message_length: max_message_length, port: port) adapter = Adapter.new(messenger) Sumac.new(duck_types: duck_types, entry: entry, messenger: adapter, workers: workers) end
listen(duck_types: {}, entry: nil, entry_class: nil, max_message_length: Float::INFINITY, port: , workers: 1)
click to toggle source
# File lib/tcp_sumac.rb, line 20 def self.listen(duck_types: {}, entry: nil, entry_class: nil, max_message_length: Float::INFINITY, port: , workers: 1) tcp_messenger_server = TCPMessenger.listen(duck_types: duck_types, max_message_length: max_message_length, port: port) Server.new(tcp_messenger_server, duck_types: duck_types, entry: entry, entry_class: entry_class, max_message_length: max_message_length, workers: workers) end