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