ScaleoutSubscription Constructor
.NET Framework 4
Namespace: Microsoft.AspNet.SignalR.Messaging
Assembly: Microsoft.AspNet.SignalR.Core (in Microsoft.AspNet.SignalR.Core.dll)
Syntax
'Declaration
Public Sub New ( _
identity As String, _
eventKeys As IEnumerable(Of String), _
cursor As String, _
streamMappings As ConcurrentDictionary(Of String, IndexedDictionary(Of ULong, ScaleoutMapping)), _
callback As Func(Of MessageResult, Task(Of Boolean)), _
maxMessages As Integer, _
counters As IPerformanceCounterManager _
)
'Usage
Dim identity As String
Dim eventKeys As IEnumerable(Of String)
Dim cursor As String
Dim streamMappings As ConcurrentDictionary(Of String, IndexedDictionary(Of ULong, ScaleoutMapping))
Dim callback As Func(Of MessageResult, Task(Of Boolean))
Dim maxMessages As Integer
Dim counters As IPerformanceCounterManager
Dim instance As New ScaleoutSubscription(identity, _
eventKeys, cursor, streamMappings, _
callback, maxMessages, counters)
public ScaleoutSubscription(
string identity,
IEnumerable<string> eventKeys,
string cursor,
ConcurrentDictionary<string, IndexedDictionary<ulong, ScaleoutMapping>> streamMappings,
Func<MessageResult, Task<bool>> callback,
int maxMessages,
IPerformanceCounterManager counters
)
public:
ScaleoutSubscription(
String^ identity,
IEnumerable<String^>^ eventKeys,
String^ cursor,
ConcurrentDictionary<String^, IndexedDictionary<unsigned long long, ScaleoutMapping^>^>^ streamMappings,
Func<MessageResult, Task<bool>^>^ callback,
int maxMessages,
IPerformanceCounterManager^ counters
)
new :
identity:string *
eventKeys:IEnumerable<string> *
cursor:string *
streamMappings:ConcurrentDictionary<string, IndexedDictionary<uint64, ScaleoutMapping>> *
callback:Func<MessageResult, Task<bool>> *
maxMessages:int *
counters:IPerformanceCounterManager -> ScaleoutSubscription
public function ScaleoutSubscription(
identity : String,
eventKeys : IEnumerable<String>,
cursor : String,
streamMappings : ConcurrentDictionary<String, IndexedDictionary<ulong, ScaleoutMapping>>,
callback : Func<MessageResult, Task<boolean>>,
maxMessages : int,
counters : IPerformanceCounterManager
)
Parameters
- identity
Type: System.String
- eventKeys
Type: System.Collections.Generic.IEnumerable<String>
- cursor
Type: System.String
- streamMappings
Type: System.Collections.Concurrent.ConcurrentDictionary<String, IndexedDictionary<UInt64, ScaleoutMapping>>
- callback
Type: System.Func<MessageResult, Task<Boolean>>
- maxMessages
Type: System.Int32