class Redis::Connection::Synchrony

def read
  type, payload = @connection.read
  if type == :reply
    payload
  elsif type == :error
    raise payload
  elsif type == :timeout
    raise TimeoutError
  else
    raise "Unknown type #{type.inspect}"
  end
end