Function StreamNetHandler

socks/request_handler.go:144–152

(tunnelConn io.ReadWriter, accessPolicy *ipaccess.Policy, log *zerolog.Logger)

}

func StreamNetHandler(tunnelConn io.ReadWriter, accessPolicy *ipaccess.Policy, log *zerolog.Logger) {
	dialer := NewNetDialer()
	requestHandler := NewRequestHandler(dialer, accessPolicy)
	socksServer := NewConnectionHandler(requestHandler)

	if err := socksServer.Serve(tunnelConn); err != nil {
		log.Debug().Err(err).Msg("Socks stream handler error")
	}
}