def read_tuple(self):
cmd = self.read_command()<EOL>source = cmd["<STR_LIT>"]<EOL>stream = cmd["<STR_LIT>"]<EOL>values = cmd["<STR_LIT>"]<EOL>val_type = self._source_tuple_types[source].get(stream)<EOL>return Tuple(<EOL>cmd["<STR_LIT:id>"],<EOL>source,<EOL>stream,<EOL>cmd["<STR_LIT>"],<EOL>tuple(values) if val_type is None else val_type(*values),<EOL>)<EOL>
Read a tuple from the pipe to Storm.