Skip to content

IQueueCacheCursor

interface

Namespace: Orleans.Streams

Enumerates the messages in a stream.
public interface IQueueCacheCursor : IDisposable

Methods

  • GetCurrent(Exception) Get the current value.
  • MoveNext Move to next message in the stream. If it returns false, there are no more messages. The enumerator is still valid however and can be called again when more data has come in on this stream.
  • RecordDeliveryFailure Records that delivery of the current event has failed
  • Refresh(StreamSequenceToken) Refreshes the cache cursor. Called when new data is added into a cache.