Method Stream

ingress/origin_connection.go:40–42

(_ context.Context, tunnelConn io.ReadWriter, _ *zerolog.Logger)

}

func (tc *tcpConnection) Stream(_ context.Context, tunnelConn io.ReadWriter, _ *zerolog.Logger) {
	stream.Pipe(tunnelConn, tc, tc.logger)
}

func (tc *tcpConnection) Write(b []byte) (int, error) {
	if tc.writeTimeout > 0 {