| 11 | ) |
| 12 | |
| 13 | type streamHandler struct { |
| 14 | log lager.Logger |
| 15 | wg *sync.WaitGroup |
| 16 | stdoutMutex sync.Mutex |
| 17 | stderrMutex sync.Mutex |
| 18 | } |
| 19 | |
| 20 | func newStreamHandler(log lager.Logger) *streamHandler { |
| 21 | return &streamHandler{ |
nothing calls this directly
no outgoing calls
no test coverage detected