Struct ProtoMessageAwaitSnapshot

Namespace

ProtoTest.Messaging

Assembly

ProtoTest.Messaging.dll

One scan of a consumer's source: the candidate deliveries at or after the awaited position, and the wake-up the scan arms for the deliveries that arrive after it. A source whose deliveries are already held - a log the consumer reads itself - leaves Changed null, because its next wait watches that storage directly.

public readonly record struct ProtoMessageAwaitSnapshot : IEquatable<ProtoMessageAwaitSnapshot>

Implements

IEquatable<ProtoMessageAwaitSnapshot>

Inherited Members

ValueType.Equals(object)

ValueType.GetHashCode()

ValueType.ToString()

object.Equals(object, object)

object.GetType()

object.ReferenceEquals(object, object)

Extension Methods

SheetModelAssertions.ShouldMatchShape<TRow>(TRow, object, bool, JsonSerializerOptions?)

SheetModelAssertions.ShouldMatchShape<TRow>(TRow, object, JsonSerializerOptions?)

Constructors

ProtoMessageAwaitSnapshot(IReadOnlyList<ProtoMessageAwaitEntry>, Task?)

One scan of a consumer's source: the candidate deliveries at or after the awaited position, and the wake-up the scan arms for the deliveries that arrive after it. A source whose deliveries are already held - a log the consumer reads itself - leaves Changed null, because its next wait watches that storage directly.

public ProtoMessageAwaitSnapshot(IReadOnlyList<ProtoMessageAwaitEntry> Candidates, Task? Changed)

Parameters

Candidates IReadOnlyList<ProtoMessageAwaitEntry>

Changed Task

Properties

Candidates

public IReadOnlyList<ProtoMessageAwaitEntry> Candidates { get; init; }

Property Value

IReadOnlyList<ProtoMessageAwaitEntry>

Changed

public Task? Changed { get; init; }

Property Value

Task