code: func (u *DropsondeUnmarshallerCollection) Run(inputChan <-chan []byte, outputChan chan<- *events.Envelope, waitGroup *sync.WaitGroup) {
  	for _, unmarshaller := range u.unmarshallers {
  		go func(um *DropsondeUnmarshaller) {
  			defer waitGroup.Done()
  			um.Run(inputChan, outputChan)
  		}(unmarshaller)
  	}
  }
docs: // Run calls Run on each marshaller in its collection.
  // This is done in separate go routines.