Class DelegatingMessageBus

Namespace

Xunit.v3

Assembly

xunit.v3.core.dll

Implementation of IMessageBus that delegates to another implementation of IMessageBus while calling into an optional callback for each message.

public class DelegatingMessageBus : IMessageBus, IDisposable

Inheritance

object

DelegatingMessageBus

Implements

IMessageBus

IDisposable

Derived

DelegatingMessageBus<TFinalMessage>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DelegatingMessageBus(IMessageBus, Action<IMessageSinkMessage>?)

Implementation of IMessageBus that delegates to another implementation of IMessageBus while calling into an optional callback for each message.

public DelegatingMessageBus(IMessageBus innerMessageBus, Action<IMessageSinkMessage>? callback = null)

Parameters

innerMessageBus IMessageBus

The message bus to delegate to.

callback Action<IMessageSinkMessage>

The callback to send messages to.

Methods

Dispose()

public void Dispose()

QueueMessage(IMessageSinkMessage)

Queues a message to be sent to the runner.

public virtual bool QueueMessage(IMessageSinkMessage message)

Parameters

message IMessageSinkMessage

The message to be sent to the runner

Returns

bool

Returns true if discovery/execution should continue; false, otherwise. The return value may be safely ignored by components which are not directly responsible for discovery or execution, and this is intended to communicate to those sub-systems that that they should short circuit and stop their work as quickly as is reasonable.