Program.cs

using Nethereum.Contracts;
using Nethereum.JsonRpc.WebSocketStreamingClient;
using Nethereum.RPC.Eth.DTOs;
using System;
using System.Reactive.Linq;
using System.Threading;
using Nethereum.Contracts.Extensions;
using Nethereum.ABI.FunctionEncoding.Attributes;
using System.Numerics;
using Nethereum.JsonRpc.Client.Streaming;
using Nethereum.RPC.Eth.Subscriptions;
using Nethereum.RPC.Reactive.Eth;
using Nethereum.RPC.Reactive.Eth.Subscriptions;
using Nethereum.RPC.Reactive.Extensions;
using Nethereum.JsonRpc.WebSocketClient;
using Nethereum.RPC.Web3;
using Nethereum.Hex.HexTypes;
using System.Threading.Tasks;
using Nethereum.RPC.Reactive.Eth.Transactions;
using System.Collections.Concurrent;

namespace Nethereum.Templates.WebSocketStreaming
{
    class Program
    {
        static async Task Main(string[] args)
        {
            //please dont use this infuraId think about the children
            //
            var url = "wss://mainnet.infura.io/ws/v3/206cfadcef274b49a3a15c45c285211c";
            // var url = "ws://fullnode.dappnode:8546";
            //var example = new ExamplePendingTransactionsWithTransactionsUsingSameClient(url);
            ///var example = new ExamplePendingTransactionsWithTransactionsUsingClientAndConcurrentQueue(url);
            //var example = new ExampleNewHeaderSubscription(url);
            //var example = new ExampleNormalRPCCalls(url);
            //var example = new ExampleLogsERC20Subscriptions(url);
            var example = new ExampleLogsUniswapSwapsSubscription(url);
            //var example = new ExampleLogsUniswapSyncSubscription(url);

            await example.SubscribeAndRunAsync();

            Console.ReadLine();
        }




    }
}