socketry
diff --git a/‎examples/mud/client.rb
Lines changed: 11 additions & 2 deletions b/‎examples/mud/client.rb
Lines changed: 11 additions & 2 deletions
diff --git a/‎examples/mud/config.ru
Lines changed: 7 additions & 4 deletions b/‎examples/mud/config.ru
Lines changed: 7 additions & 4 deletions
@@ -20,15 +20,24 @@
 			$stdout.write "> "
 
 			while line = $stdin.gets
-				connection.write({input: line})
+				connection.write(Protocol::WebSocket::TextMessage.generate({input: line}))
 				connection.flush
 
 				$stdout.write "> "
 			end
 		end
 
 		while message = connection.read
-			$stdout.puts message
+			# Rewind to start of line:
+			$stdout.write "\r"
+			
+			# Clear line:
+			$stdout.write "\e[2K"
+			
+			# Print message:
+			$stdout.puts message.to_h
+			
+			$stdout.write "> "
 		end
 	end
 end
@@ -83,25 +83,28 @@ class User < Async::WebSocket::Connection
 		@name || ANONYMOUS
 	end
 
+	def send_message(value)
+		self.write(Protocol::WebSocket::TextMessage.generate(value))
+	end
+	
 	def handle(message)
-		key, *arguments = Command.split(message[:input])
+		key, *arguments = Command.split(message.parse[:input])
 		case key
 		when "name"
 			@name = arguments.first
 		when "look"
-			self.write({room: @room.as_json})
+			self.send_message({room: @room.as_json})
 		else
 			if action = @room.actions[key]
 				action.call(self, *arguments)
 			else
-				message[:user]
 				@room.broadcast(message)
 			end
 		end
 	end
 
 	def notify(text)
-		self.write({notify: text})
+		self.send_message({notify: text})
 		self.flush
 	end