diff --git a/app/reverse/portal.go b/app/reverse/portal.go index 8efe3996..cec20d27 100644 --- a/app/reverse/portal.go +++ b/app/reverse/portal.go @@ -82,6 +82,10 @@ func (p *Portal) HandleConnection(ctx context.Context, link *transport.Link) err } p.picker.AddWorker(worker) + + if _, ok := link.Reader.(*pipe.Reader); !ok { + <-ctx.Done() // from DispatchLink() + } return nil }