Skip to content

Enable stream and add cli for streaming. #2178

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 9 commits into from
May 20, 2025
Merged

Enable stream and add cli for streaming. #2178

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
6a45528
Enable stream and add cli for streaming.
vwxyzh Mar 12, 2025
bcf746c
update
vwxyzh Mar 31, 2025
ded0e6f
Merge branch 'dev' into stream
vwxyzh Apr 7, 2025
6df85d3
Merge branch 'dev' into stream
vwxyzh May 19, 2025
405f143
update
vwxyzh May 19, 2025
7897a45
update api.
vwxyzh May 19, 2025
f3d8768
Update ChatSample.Cli.csproj
vicancy May 19, 2025
b449da1
add readme
vwxyzh May 19, 2025
fc988b7
update log.
vwxyzh May 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions AzureSignalR.sln
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ManagementPublisher", "samp
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ChatSample.RazorPages", "samples\ChatSample\ChatSample.RazorPages\ChatSample.RazorPages.csproj", "{D7A38BB7-6416-4E15-AD87-D525F203F549}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ChatSample.Cli", "samples\ChatSample.Cli\ChatSample.Cli.csproj", "{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
Expand Down Expand Up @@ -196,6 +198,10 @@ Global
{D7A38BB7-6416-4E15-AD87-D525F203F549}.Debug|Any CPU.Build.0 = Debug|Any CPU
{D7A38BB7-6416-4E15-AD87-D525F203F549}.Release|Any CPU.ActiveCfg = Release|Any CPU
{D7A38BB7-6416-4E15-AD87-D525F203F549}.Release|Any CPU.Build.0 = Release|Any CPU
{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31}.Debug|Any CPU.Build.0 = Debug|Any CPU
{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31}.Release|Any CPU.ActiveCfg = Release|Any CPU
{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
Expand Down Expand Up @@ -229,6 +235,7 @@ Global
{82C1FF3D-EC6C-4B21-B6A4-E69E8D75D0D0} = {2429FBD8-1FCE-4C42-AA28-DF32F7249E77}
{0F32E624-7AC8-4CA7-8ED9-E1A877442020} = {C965ED06-6A17-4329-B3C6-811830F4F4ED}
{D7A38BB7-6416-4E15-AD87-D525F203F549} = {C965ED06-6A17-4329-B3C6-811830F4F4ED}
{45EFE0AE-DE2F-EED2-55FC-9213D2AB9F31} = {C965ED06-6A17-4329-B3C6-811830F4F4ED}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {7945A4E4-ACDB-4F6E-95CA-6AC6E7C2CD59}
Expand Down
12 changes: 12 additions & 0 deletions api/Microsoft.Azure.SignalR.Management.net6.0.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,11 @@ public partial interface IServiceManagerBuilder
[System.ObsoleteAttribute("Use ServiceManagerBuilder.BuildServiceManager() instead.")]
Microsoft.Azure.SignalR.Management.IServiceManager Build();
}
public partial interface IStreamingManager
{
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public partial interface IUserGroupManager
{
System.Threading.Tasks.Task AddToGroupAsync(string userId, string groupName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken));
Expand Down Expand Up @@ -70,6 +75,7 @@ protected ServiceHubContext() { }
public virtual Microsoft.Azure.SignalR.Management.GroupManager Groups { get { throw null; } }
Microsoft.AspNetCore.SignalR.IGroupManager Microsoft.AspNetCore.SignalR.IHubContext<Microsoft.AspNetCore.SignalR.Hub>.Groups { get { throw null; } }
Microsoft.Azure.SignalR.Management.IUserGroupManager Microsoft.Azure.SignalR.Management.IServiceHubContext.UserGroups { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.StreamingManager Streaming { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.UserGroupManager UserGroups { get { throw null; } }
public virtual void Dispose() { }
public virtual System.Threading.Tasks.Task DisposeAsync() { throw null; }
Expand Down Expand Up @@ -151,6 +157,12 @@ public enum ServiceTransportType
Transient = 0,
Persistent = 1,
}
public abstract partial class StreamingManager : Microsoft.Azure.SignalR.Management.IStreamingManager
{
protected StreamingManager() { }
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public abstract partial class UserGroupManager : Microsoft.Azure.SignalR.Management.IUserGroupManager
{
protected UserGroupManager() { }
Expand Down
12 changes: 12 additions & 0 deletions api/Microsoft.Azure.SignalR.Management.net8.0.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,11 @@ public partial interface IServiceManagerBuilder
[System.ObsoleteAttribute("Use ServiceManagerBuilder.BuildServiceManager() instead.")]
Microsoft.Azure.SignalR.Management.IServiceManager Build();
}
public partial interface IStreamingManager
{
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public partial interface IUserGroupManager
{
System.Threading.Tasks.Task AddToGroupAsync(string userId, string groupName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken));
Expand Down Expand Up @@ -70,6 +75,7 @@ protected ServiceHubContext() { }
public virtual Microsoft.Azure.SignalR.Management.GroupManager Groups { get { throw null; } }
Microsoft.AspNetCore.SignalR.IGroupManager Microsoft.AspNetCore.SignalR.IHubContext<Microsoft.AspNetCore.SignalR.Hub>.Groups { get { throw null; } }
Microsoft.Azure.SignalR.Management.IUserGroupManager Microsoft.Azure.SignalR.Management.IServiceHubContext.UserGroups { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.StreamingManager Streaming { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.UserGroupManager UserGroups { get { throw null; } }
public virtual void Dispose() { }
public virtual System.Threading.Tasks.Task DisposeAsync() { throw null; }
Expand Down Expand Up @@ -158,6 +164,12 @@ public enum ServiceTransportType
Transient = 0,
Persistent = 1,
}
public abstract partial class StreamingManager : Microsoft.Azure.SignalR.Management.IStreamingManager
{
protected StreamingManager() { }
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public abstract partial class UserGroupManager : Microsoft.Azure.SignalR.Management.IUserGroupManager
{
protected UserGroupManager() { }
Expand Down
12 changes: 12 additions & 0 deletions api/Microsoft.Azure.SignalR.Management.netstandard2.0.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,11 @@ public partial interface IServiceManagerBuilder
[System.ObsoleteAttribute("Use ServiceManagerBuilder.BuildServiceManager() instead.")]
Microsoft.Azure.SignalR.Management.IServiceManager Build();
}
public partial interface IStreamingManager
{
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public partial interface IUserGroupManager
{
System.Threading.Tasks.Task AddToGroupAsync(string userId, string groupName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken));
Expand Down Expand Up @@ -70,6 +75,7 @@ protected ServiceHubContext() { }
public virtual Microsoft.Azure.SignalR.Management.GroupManager Groups { get { throw null; } }
Microsoft.AspNetCore.SignalR.IGroupManager Microsoft.AspNetCore.SignalR.IHubContext<Microsoft.AspNetCore.SignalR.Hub>.Groups { get { throw null; } }
Microsoft.Azure.SignalR.Management.IUserGroupManager Microsoft.Azure.SignalR.Management.IServiceHubContext.UserGroups { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.StreamingManager Streaming { get { throw null; } }
public virtual Microsoft.Azure.SignalR.Management.UserGroupManager UserGroups { get { throw null; } }
public virtual void Dispose() { }
public virtual System.Threading.Tasks.Task DisposeAsync() { throw null; }
Expand Down Expand Up @@ -151,6 +157,12 @@ public enum ServiceTransportType
Transient = 0,
Persistent = 1,
}
public abstract partial class StreamingManager : Microsoft.Azure.SignalR.Management.IStreamingManager
{
protected StreamingManager() { }
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Collections.Generic.IAsyncEnumerable<TItem> items, System.Threading.CancellationToken cancellationToken);
public abstract System.Threading.Tasks.Task SendStreamAsync<TItem>(string connectionId, string streamId, System.Threading.Channels.ChannelReader<TItem> items, System.Threading.CancellationToken cancellationToken);
}
public abstract partial class UserGroupManager : Microsoft.Azure.SignalR.Management.IUserGroupManager
{
protected UserGroupManager() { }
Expand Down
26 changes: 26 additions & 0 deletions samples/ChatSample.Cli/ChatSample.Cli.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
<Project Sdk="Microsoft.NET.Sdk">

<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
<PublishSingleFile>true</PublishSingleFile>
</PropertyGroup>

<ItemGroup>
<Content Include="chat.txt">
<CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
</Content>
</ItemGroup>

<ItemGroup>
<PackageReference Include="Microsoft.AspNetCore.SignalR.Client" Version="$(MicrosoftAspNetCoreSignalRCommonNet8PackageVersion)" />
<PackageReference Include="Microsoft.AspNetCore.SignalR.Protocols.MessagePack" Version="$(MicrosoftAspNetCoreSignalRCommonNet8PackageVersion)" />
</ItemGroup>

<ItemGroup>
<ProjectReference Include="..\..\src\Microsoft.Azure.SignalR.Management\Microsoft.Azure.SignalR.Management.csproj" />
</ItemGroup>

</Project>
12 changes: 12 additions & 0 deletions samples/ChatSample.Cli/Extensions.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

namespace ChatSample.Cli;

internal static class Extensions
{
public static TBuilder When<TBuilder>(this TBuilder self, bool condition, Func<TBuilder, TBuilder> func)
{
return condition ? func(self) : self;
}
}
Loading
Loading