def _add_out_streams(self, spbl):
if self.outputs is None:<EOL><INDENT>return<EOL><DEDENT>output_map = self._sanitize_outputs()<EOL>for stream_id, out_fields in output_map.items():<EOL><INDENT>out_stream = spbl.outputs.add()<EOL>out_stream.stream.CopyFrom(self._get_stream_id(self.name, stream_id))<EOL>out_stream.schema.CopyFrom(self._get_stream_schema(out_fields))<EOL><DEDENT>
Adds outputs to a given protobuf Bolt or Spout message