code: def _get_spout(self):
      
      spout = topology_pb2.Spout()
      spout.comp.CopyFrom(self._get_base_component())
  
      # Add output streams
      self._add_out_streams(spout)
      return spout
docs: Returns Spout protobuf message