(remoteConn sockjs.Session)
| 38 | } |
| 39 | |
| 40 | func (t *Tunnel) Run(remoteConn sockjs.Session) { |
| 41 | close(t.startChan) |
| 42 | <-JoinStreams(SessionReadWriteCloser{t.localConn}, SessionReadWriteCloser{remoteConn}) |
| 43 | t.Close() |
| 44 | } |
| 45 | |
| 46 | func JoinStreams(local, remote io.ReadWriteCloser) chan error { |
| 47 | errc := make(chan error, 2) |
nothing calls this directly
no test coverage detected