Better control process - can execute code.

examples/chat/client.rb

@@ -18,17 +18,9 @@
 	endpoint.connect do |socket|
 		connection = Async::WebSocket::Client.new(socket, URL)
 
-		connection.send_message({
-			user: USER,
-			status: "connected",
-		})
-
 		input_task = task.async do
 			while line = stdin.read_until("\n")
-				connection.send_message({
-					user: USER,
-					text: line,
-				})
+				connection.send_message({text: line})
 			end
 		end
 

examples/chat/config.ru

@@ -25,6 +25,12 @@ class Room
 		@connections.each(&block)
 	end
 
+	def command(code)
+		Async.logger.warn self, "eval(#{code})"
+
+		eval(code)
+	end
+
 	def broadcast(message)
 		Async.logger.info "Broadcast: #{message.inspect}"
 		start_time = Async::Clock.now
@@ -45,7 +51,21 @@ class Room
 				self.connect(connection)
 
 				while message = connection.next_message
-					self.broadcast(message)
+					if message["text"] =~ /^\/(.*?)$/
+						begin
+							result = self.command($1)
+
+							if result.is_a? Hash
+								connection.send_message(result)
+							else
+								connection.send_message({result: result.inspect})
+							end
+						rescue
+							connection.send_message({error: $!.inspect})
+						end
+					else
+						self.broadcast(message)
+					end
 				end
 			ensure
 				self.disconnect(connection)

examples/chat/multi-client.rb

@@ -31,7 +31,7 @@ def call
 		count = @options[:count]
 
 		connections = Async::Queue.new
-		progress = TTY::ProgressBar.new("connections [:bar] :current/:total (:eta/:elapsed)", total: count)
+		progress = TTY::ProgressBar.new(":rate connection/s [:bar] :current/:total (:eta/:elapsed)", total: count)
 
 		Async do |task|
 			task.logger.info!

examples/middleware/client.rb

@@ -15,7 +15,7 @@
 
 	endpoint = Async::HTTP::URLEndpoint.parse(URL)
 
-	endpoint.connect do |socket|
+	endpoint.with(local_address: local_address).connect do |socket|
 		connection = Async::WebSocket::Client.new(socket, URL)
 
 		connection.send_message({