class Async::Container::Supervisor::Connection

def read

def read
	if line = @stream&.gets
		JSON.parse(line, symbolize_names: true)
	end
end