williamcotton: upload.pipe(redisQuery); redisQuery.pipe(resp)