syncContextPipe is a pipe that is able to handle timeouts via contexts.
| 8 | |
| 9 | // syncContextPipe is a pipe that is able to handle timeouts via contexts. |
| 10 | type syncContextPipe struct { |
| 11 | byteChannel chan byte |
| 12 | closed bool |
| 13 | lock *sync.Mutex |
| 14 | } |
| 15 | |
| 16 | func (c *syncContextPipe) Write(data []byte) (int, error) { |
| 17 | return c.WriteCtx(context.Background(), data) |
nothing calls this directly
no outgoing calls
no test coverage detected