Class AbstractSubscribableChannelWriter

Namespace

Steeltoe.Integration.Channel

Assembly

Steeltoe.Integration.IntegrationBase.dll

public abstract class AbstractSubscribableChannelWriter : AbstractMessageChannelWriter

Inheritance

object

ChannelWriter<IMessage>

AbstractMessageChannelWriter

AbstractSubscribableChannelWriter

Derived

DirectChannelWriter

PublishSubscribeChannelWriter

TaskSchedulerChannelWriter

Inherited Members

AbstractMessageChannelWriter.channel

AbstractMessageChannelWriter.logger

AbstractMessageChannelWriter.TryComplete(Exception)

AbstractMessageChannelWriter.TryWrite(IMessage)

AbstractMessageChannelWriter.WriteAsync(IMessage, CancellationToken)

ChannelWriter<IMessage>.Complete(Exception)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractSubscribableChannelWriter(AbstractSubscribableChannel, ILogger)

protected AbstractSubscribableChannelWriter(AbstractSubscribableChannel channel, ILogger logger = null)

Parameters

channel AbstractSubscribableChannel

logger ILogger

Properties

Channel

public virtual AbstractSubscribableChannel Channel { get; }

Property Value

AbstractSubscribableChannel

Methods

WaitToWriteAsync(CancellationToken)

Returns a ValueTask<TResult> that will complete when space is available to write an item.

public override ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

A CancellationToken used to cancel the wait operation.

Returns

ValueTask<bool>

A ValueTask<TResult> that will complete with a true result when space is available to write an item or with a false result when no further writing will be permitted.