bertt · September 15, 2017 07:53
diff --git a/connection.cs b/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");
diff --git a/connection.js b/connection.js
 let connection = new signalR.HubConnection('/chat');

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

 connection.start()
          .then(() => connection.invoke('send', 'Hello'));
diff --git a/hub.cs b/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);
        }
    }
 }
diff --git a/npminstall b/npminstall
 npm install @aspnet/signalr-client
diff --git a/observable.cs b/observable.cs
 public IObservable<Stock> StreamStocks()
 {
    return _stockTicker.StreamStocks();
 }
diff --git a/project.csproj b/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>
diff --git a/project2.csproj b/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>
diff --git a/script.html b/script.html
 <script src="scripts/signalr-client.min.js"></script>
diff --git a/startup.cs b/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");
            });
        }
    }
 }
diff --git a/streaming.cs b/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}");
        }
    }
 }
diff --git a/streaming.js b/streaming.js
 function startStreaming() {
    connection.stream("StreamStocks").subscribe({
        next: displayStocks,
        error: function (err) {
            logger.log(err);
        }
    });
 }
	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");
	let connection = new signalR.HubConnection('/chat');

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

	connection.start()
	.then(() => connection.invoke('send', 'Hello'));
	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);
	}
	}
	}
	public IObservable<Stock> StreamStocks()
	{
	return _stockTicker.StreamStocks();
	}
	<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>
	<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>
	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");
	});
	}
	}
	}
	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}");
	}
	}
	}
	function startStreaming() {
	connection.stream("StreamStocks").subscribe({
	next: displayStocks,
	error: function (err) {
	logger.log(err);
	}
	});
	}