SignalRAnnouncement

connection.cs

var connection = new HubConnectionBuilder()
                .WithUrl("http://localhost:5000/chat")
                .WithConsoleLogger()
                .Build();

connection.On<string>("Send", data =>
{
    Console.WriteLine($"Received: {data}");
});

await connection.StartAsync();

await connection.InvokeAsync("Send", "Hello");

connection.js

let connection = new signalR.HubConnection('/chat');

connection.on('send', data => {
    console.log(data);
});

connection.start()
          .then(() => connection.invoke('send', 'Hello'));

hub.cs

using System;
using System.Threading.Tasks;
using Microsoft.AspNetCore.SignalR;

namespace Sample
{
    public class Chat : Hub
    {
        public Task Send(string message)
        {
            return Clients.All.InvokeAsync("Send", message);
        }
    }
}

npminstall

npm install @aspnet/signalr-client

observable.cs

public IObservable<Stock> StreamStocks()
{
    return _stockTicker.StreamStocks();
}

project.csproj

<Project Sdk="Microsoft.NET.Sdk.Web">

  <PropertyGroup>
    <TargetFramework>netcoreapp2.0</TargetFramework>
  </PropertyGroup>

  <ItemGroup>
    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.0" />
    <PackageReference Include="Microsoft.AspNetCore.SignalR" Version="1.0.0-alpha1-final" />
  </ItemGroup>

  <ItemGroup>
    <Folder Include="wwwroot\scripts\" />
  </ItemGroup>

</Project>

project2.csproj

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp2.0</TargetFramework>
  </PropertyGroup>

  <ItemGroup>
    <PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="1.0.0-alpha1-final" />
  </ItemGroup>

</Project>

script.html

<script src="scripts/signalr-client.min.js"></script>

startup.cs

using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.DependencyInjection;

namespace Sample
{
    public class Startup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddSignalR();
        }

        public void Configure(IApplicationBuilder app)
        {
            app.UseFileServer();
            app.UseSignalR(routes =>
            {
                routes.MapHub<Chat>("chat");
            });
        }
    }
}

streaming.cs

private async Task StartStreaming()
{
    var channel = connection.Stream<Stock>("StreamStocks", CancellationToken.None);
    while (await channel.WaitToReadAsync())
    {
        while (channel.TryRead(out var stock))
        {
            Console.WriteLine($"{stock.Symbol} {stock.Price}");
        }
    }
}

streaming.js

function startStreaming() {
    connection.stream("StreamStocks").subscribe({
        next: displayStocks,
        error: function (err) {
            logger.log(err);
        }
    });
}