code-sharp / wampsharp-docs Goto Github PK

Install-Package : Version conflict detected for System.Collections.Immutable. 
 CrossBarTest (≥ 1.0.0) -> Microsoft.NETCore.UniversalWindowsPlatform (≥ 5.0.0) -> Microsoft.NETCore (≥ 5.0.0) -> 
System.Collections.Immutable (≥ 1.1.37) 
 CrossBarTest (≥ 1.0.0) -> WampSharp.Default (≥ 1.2.3.12-beta) -> WampSharp.Default.Client (= 1.2.3.12-beta) -> 
WampSharp.NewtonsoftJson (= 1.2.3.12-beta) -> WampSharp (= 1.2.3.12-beta) -> System.Collections.Immutable (= 1.1.36).
At line:1 char:1
+ Install-Package WampSharp.Default -Pre
+ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    + CategoryInfo          : NotSpecified: (:) [Install-Package], Exception
    + FullyQualifiedErrorId : NuGetCmdletUnhandledException,NuGet.PackageManagement.PowerShellCmdlets.InstallPackageCommand

Install-Package : Version conflict detected for System.Collections.Immutable. 
 CrossBarTest (≥ 1.0.0) -> Microsoft.NETCore.UniversalWindowsPlatform (≥ 5.0.0) -> Microsoft.NETCore (≥ 5.0.0) -> 
System.Collections.Immutable (≥ 1.1.37) 
 CrossBarTest (≥ 1.0.0) -> WampSharp.Default (≥ 1.2.3.12-beta) -> WampSharp.Default.Client (= 1.2.3.12-beta) -> 
WampSharp.Windows (= 1.2.3.12-beta) -> WampSharp (= 1.2.3.12-beta) -> System.Collections.Immutable (= 1.1.36).
At line:1 char:1
+ Install-Package WampSharp.Default -Pre
+ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    + CategoryInfo          : NotSpecified: (:) [Install-Package], Exception
    + FullyQualifiedErrorId : NuGetCmdletUnhandledException,NuGet.PackageManagement.PowerShellCmdlets.InstallPackageCommand

using System;
using System.Reactive.Linq;
using System.Reactive.Subjects;
using System.Threading.Tasks;
using WampSharp.V2;
using WampSharp.V2.Client;


namespace Wamp
{
    internal class Program
    {
        public static void Main(string[] args)
        {
            DefaultWampChannelFactory factory =
                new DefaultWampChannelFactory();

            const string serverAddress = "wss://api.poloniex.com";

            IWampChannel channel =
                factory.CreateJsonChannel(serverAddress, "realm1");

            channel.Open().Wait(5000);

            IWampRealmProxy realmProxy = channel.RealmProxy;

            int received = 0;
            IDisposable subscription = null;

            subscription =
                realmProxy.Services.GetSubject<int>("BTC_XMR")
                    .Subscribe(x =>
                        {
                            Console.WriteLine("Got Event: " + x);

                            received++;

                            if (received > 5)
                            {
                                Console.WriteLine("Closing ..");
                                subscription.Dispose();
                            }
                        });

            Console.ReadLine();
        }
    }
}