(data []byte)
| 16 | } |
| 17 | |
| 18 | func (s *processStream) Write(data []byte) (int, error) { |
| 19 | d := string(data) |
| 20 | stdin := transport.Stdin |
| 21 | return len(data), s.sendPayload(transport.ProcessPayload{ |
| 22 | ProcessID: s.processID, |
| 23 | Source: &stdin, |
| 24 | Data: &d, |
| 25 | }) |
| 26 | } |
| 27 | |
| 28 | func (s *processStream) Close() error { |
| 29 | stdin := transport.Stdin |
no test coverage detected