()
| 81 | return nil |
| 82 | } |
| 83 | func (s *bidirectionalStreamStatus) isAnyDone() bool { |
| 84 | return atomic.LoadUint32(&s.anyDone) > 0 |
| 85 | } |
| 86 | |
| 87 | // Pipe copies copy data to & from provided io.ReadWriters. |
| 88 | func Pipe(tunnelConn, originConn io.ReadWriter, log *zerolog.Logger) { |
no outgoing calls
no test coverage detected