Class StreamConnector

Inherit to connect processing stages to Source to receive incoming SignalR client messages, and connect processing stages to Sink to send outgoing messages to SignalR clients.

Inheritance

Object

StreamConnector

Namespace: Akka.Streams.SignalR.AspNetCore

Assembly: Akka.Streams.SignalR.AspNetCore.dll

Syntax

public abstract class StreamConnector : object

Constructors

| Improve this Doc View Source

StreamConnector(IHubClients, ConnectionSourceSettings, ConnectionSinkSettings)

Creates a new instance of StreamConnector.

Declaration

protected StreamConnector(IHubClients clients, ConnectionSourceSettings sourceSettings = null, ConnectionSinkSettings sinkSettings = null)

Parameters

Type	Name	Description
IHubClients	clients
ConnectionSourceSettings	sourceSettings	Optional settings used to configure the Source.
ConnectionSinkSettings	sinkSettings	Optional settings used to configure the Sink.

Properties

| Improve this Doc View Source

Sink

An Akka.Streams sink for messages send back to the client. Can be integrated with Akka.Streams flow graphs.

Declaration

public Sink<ISignalRResult, NotUsed> Sink { get; }

Property Value

Type	Description
Sink<ISignalRResult, NotUsed>

| Improve this Doc View Source

Source

An Akka.Streams source used for events related with the connection. Can be integrated with Akka.Streams flow graphs.

Keep in mind, that in current version SignalR doesn't support backressure mechanism. Incoming events, that cannot be processed in time, will be buffered up to the BufferCapacity size, and once buffer will overflow, an OverflowStrategy will be applied.

Declaration

public Source<ISignalREvent, NotUsed> Source { get; }

Property Value

Type	Description
Source<ISignalREvent, NotUsed>