* updated reading to read until you see a message for your stream * added timeout to decode uvarint * resolved comments * shortened long line