kubernetes/staging/src/k8s.io/client-go/tools/portforward/tunneling_connection_test.go

func TestTunnelingConnection_ReadWriteClose(t *testing.T) { … }

func TestTunnelingConnection_LocalRemoteAddress(t *testing.T) { … }

func TestTunnelingConnection_ReadWriteDeadlines(t *testing.T) { … }

// dialForTunnelingConnection upgrades a request at the passed "url", creating
// a websocket connection. Returns the TunnelingConnection injected with the
// websocket connection or an error if one occurs.
func dialForTunnelingConnection(url *url.URL) (*TunnelingConnection, error) { … }

func justQueueStream(streams chan httpstream.Stream) func(httpstream.Stream, <-chan struct{ … }