func (p msgProcessor) process(msg []byte) error {
	for _, handler := range p.handlers {
		err := handler(msg)
		if err != nil {
			return err
		}
	}
	return nil
}
// process just passes msg into all handler, aborts if any errors
process just passes msg into all handler, aborts if any errors
// process just passes msg into all handler aborts if any errors
func (p msgProcessor) process(msg []byte) error {
	for _, handler := range p.handlers {
		err := handler(msg)
		if err != nil {
			return err
		}
	}
	return nil
}
func ( p msgProcessor ) process ( msg [ ] byte ) error { for _ , handler := range p . handlers { err := handler ( msg ) if err != nil { return err } } return nil }
process just passes msg into all handler, aborts if any errors
process just passes msg into all handler aborts if any errors