in setuptest/logger.go [59:64]
func (s *StreamLogger) PipeFrom(srcLogger *StreamLogger) error { s.mu.Lock() defer s.mu.Unlock() _, err := io.Copy(s.stream, srcLogger.stream) return err }