X

Class QueueChannelReader

Inheritance
System.Object
QueueChannelReader
Namespace: Steeltoe.Integration.Channel
Assembly: Steeltoe.Integration.IntegrationBase.dll
Syntax
public class QueueChannelReader : ChannelReader<IMessage>

Constructors

| Edit this page View Source

QueueChannelReader(QueueChannel, ILogger)

Declaration
public QueueChannelReader(QueueChannel channel, ILogger logger = null)
Parameters
Type Name Description
QueueChannel channel
ILogger logger

Properties

| Edit this page View Source

Channel

Declaration
protected QueueChannel Channel { get; }
Property Value
Type Description
QueueChannel

Methods

| Edit this page View Source

ReadAllAsync(CancellationToken)

Declaration
public override IAsyncEnumerable<IMessage> ReadAllAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
IAsyncEnumerable<IMessage>
| Edit this page View Source

ReadAsync(CancellationToken)

Declaration
public override ValueTask<IMessage> ReadAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
ValueTask<IMessage>
| Edit this page View Source

TryRead(out IMessage)

Declaration
public override bool TryRead(out IMessage item)
Parameters
Type Name Description
IMessage item
Returns
Type Description
System.Boolean
| Edit this page View Source

WaitToReadAsync(CancellationToken)

Declaration
public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken = null)
Parameters
Type Name Description
CancellationToken cancellationToken
Returns
Type Description
ValueTask<System.Boolean>