mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-04 09:49:50 +00:00
Merge pull request #6636 from ncdc/fix-flakey-portforward-test
Fix flakey port forward test
This commit is contained in:
commit
554efa642c
@ -138,7 +138,10 @@ func (c *fakeUpgradeConnection) CreateStream(headers http.Header) (httpstream.St
|
|||||||
|
|
||||||
stream := &fakeUpgradeStream{}
|
stream := &fakeUpgradeStream{}
|
||||||
c.streams[headers.Get(api.PortHeader)] = stream
|
c.streams[headers.Get(api.PortHeader)] = stream
|
||||||
|
// only simulate data on the data stream for now, not the error stream
|
||||||
|
if headers.Get(api.StreamType) == api.StreamTypeData {
|
||||||
stream.data = c.portData[headers.Get(api.PortHeader)]
|
stream.data = c.portData[headers.Get(api.PortHeader)]
|
||||||
|
}
|
||||||
|
|
||||||
return stream, nil
|
return stream, nil
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user