Skip to content

Commit abfe414

Browse files
committed
fix: make port forwarding non-blocking
1 parent 4a779ef commit abfe414

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

pkg/devspace/kubectl/portforward/portforward.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -191,9 +191,11 @@ func NewOnAddresses(dialer httpstream.Dialer, addresses []string, ports []string
191191
}
192192

193193
func (pf *PortForwarder) raiseError(err error) {
194-
if pf.errChan != nil {
195-
pf.errChan <- err
196-
}
194+
go func() {
195+
if pf.errChan != nil {
196+
pf.errChan <- err
197+
}
198+
}()
197199

198200
_ = pf.streamConn.Close()
199201
}

0 commit comments

Comments
 (0)