convertRequests function
(reqs <-chan *ssh.Request)
| 376 | |
| 377 | // convertRequests function |
| 378 | func convertRequests(reqs <-chan *ssh.Request) <-chan tunnelssh.SSHRequest { |
| 379 | out := make(chan tunnelssh.SSHRequest) |
| 380 | go func() { |
| 381 | for req := range reqs { |
| 382 | out <- &sshRequest{req} |
| 383 | } |
| 384 | close(out) |
| 385 | }() |
| 386 | return out |
| 387 | } |
| 388 | |
| 389 | func handleChannels(ctx context.Context, server *relayServer, chans <-chan ssh.NewChannel) error { |
| 390 | errc := make(chan error, 1) |