Class StreamHub<TStream>

A variant of able to cooperate with Akka.Streams API. Note this is instantiated by AspNetCore framework on EVERY method call - it should not carry state.

Inheritance
Object
StreamHub<TStream>
Implements
Namespace: Akka.Streams.SignalR.AspNetCore
Assembly: Akka.Streams.SignalR.AspNetCore.dll
Syntax
public abstract class StreamHub<TStream> : Hub<IClientSink>, IServerSource where TStream : StreamConnector
Type Parameters
Name Description
TStream

Constructors

| Improve this Doc View Source

StreamHub(IStreamDispatcher)

Declaration
protected StreamHub(IStreamDispatcher dispatcher)
Parameters
Type Name Description
IStreamDispatcher dispatcher

Methods

| Improve this Doc View Source

OnConnectedAsync()

Declaration
public override Task OnConnectedAsync()
Returns
Type Description
Task
| Improve this Doc View Source

OnDisconnectedAsync(Exception)

Declaration
public override Task OnDisconnectedAsync(Exception ex)
Parameters
Type Name Description
Exception ex
Returns
Type Description
Task
| Improve this Doc View Source

Send(Object)

Called by SignalR clients

Declaration
public Task Send(object data)
Parameters
Type Name Description
Object data
Returns
Type Description
Task

Implements