Edit

Share via


EventHubDataComparer Class

Definition

Default eventhub data comparer. Implements comparisions against CachedEventHubMessage

public class EventHubDataComparer : Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage>
type EventHubDataComparer = class
    interface ICacheDataComparer<CachedEventHubMessage>
Public Class EventHubDataComparer
Implements ICacheDataComparer(Of CachedEventHubMessage)
Inheritance
EventHubDataComparer
Implements

Constructors

EventHubDataComparer()

Fields

Instance

Singleton instance, since type is stateless using this will reduce allocations.

Methods

Compare(CachedEventHubMessage, StreamSequenceToken)

Compare a cached message with a sequence token to determine if it message is before or after the token

Equals(CachedEventHubMessage, IStreamIdentity)

Checks to see if the cached message is part of the provided stream

Extension Methods

Compare<TCachedMessage>(ICacheDataComparer<TCachedMessage>, StreamSequenceToken, TCachedMessage)

Compare a cached message with a sequence token to determine if it message is before or after the token

Equals<TCachedMessage>(ICacheDataComparer<TCachedMessage>, IStreamIdentity, TCachedMessage)

Checks to see if the cached message is part of the provided stream

Applies to