Поделиться через

CachedMessageBlock.TryFindNextMessage Метод

  • Ссылка

Определение

Пространство имен:
Orleans.Providers.Streams.Common
Сборка:
Orleans.Streaming.dll
Сборка:
OrleansProviders.dll
Пакет:
Microsoft.Orleans.Streaming v7.2.5
Пакет:
Microsoft.Orleans.Streaming v8.0.0
Пакет:
Microsoft.Orleans.Streaming v8.1.0
Пакет:
Microsoft.Orleans.Streaming v8.2.0
Пакет:
Microsoft.Orleans.OrleansProviders v3.6.5

Перегрузки

TryFindNextMessage(Int32, StreamId, ICacheDataAdapter, Int32)

Пытается получить следующее сообщение из предоставленного потока, начиная с начального индекса.
TryFindNextMessage(Int32, IStreamIdentity, ICacheDataAdapter, Int32)

Пытается получить следующее сообщение из предоставленного потока, начиная с начального индекса.

TryFindNextMessage(Int32, StreamId, ICacheDataAdapter, Int32)

Пытается получить следующее сообщение из предоставленного потока, начиная с начального индекса.

public bool TryFindNextMessage (int start, Orleans.Runtime.StreamId streamId, Orleans.Providers.Streams.Common.ICacheDataAdapter dataAdapter, out int index);
member this.TryFindNextMessage : int * Orleans.Runtime.StreamId * Orleans.Providers.Streams.Common.ICacheDataAdapter * int -> bool
Public Function TryFindNextMessage (start As Integer, streamId As StreamId, dataAdapter As ICacheDataAdapter, ByRef index As Integer) As Boolean

Параметры

start
Int32

Индекс начала.

streamId
StreamId

Идентификатор потока.

dataAdapter
ICacheDataAdapter

Адаптер данных.

index
Int32

Индекс.

Возвращаемое значение

Boolean

true Значение , если сообщение найдено, в false противном случае — значение .

Применяется к

TryFindNextMessage(Int32, IStreamIdentity, ICacheDataAdapter, Int32)

Исходный код:
CachedMessageBlock.cs

Пытается получить следующее сообщение из предоставленного потока, начиная с начального индекса.

public bool TryFindNextMessage (int start, Orleans.Streams.IStreamIdentity streamIdentity, Orleans.Providers.Streams.Common.ICacheDataAdapter dataAdapter, out int index);
member this.TryFindNextMessage : int * Orleans.Streams.IStreamIdentity * Orleans.Providers.Streams.Common.ICacheDataAdapter * int -> bool
Public Function TryFindNextMessage (start As Integer, streamIdentity As IStreamIdentity, dataAdapter As ICacheDataAdapter, ByRef index As Integer) As Boolean

Параметры

start
Int32
streamIdentity
IStreamIdentity
dataAdapter
ICacheDataAdapter
index
Int32

Возвращаемое значение

Boolean

Применяется к