class Terminalwire::Server::WebSocket

def call(env)
  Async::WebSocket::Adapters::Rack.open(env, protocols: ['ws']) do |connection|
    run(Adapter::Socket.new(Terminalwire::Transport::WebSocket.new(connection)))
  end or [200, { "Content-Type" => "text/plain" }, ["Connect via WebSockets"]]
end

def run(adapter)
  while message = adapter.read
    puts message
  end
end