Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,11 @@ namespace Microsoft.Testing.Platform.Extensions;
/// <summary>
/// Represents a data consumer that can consume data produced by a data producer.
/// </summary>
/// <remarks>
/// The message bus does not dispatch data to a consumer when the consumer and producer have the same
/// <see cref="IExtension.Uid"/>. Producer and consumer registrations that communicate through the message bus
/// must use different UIDs. An extension that processes its own data should invoke that processing directly.
/// </remarks>
public interface IDataConsumer : IExtension
{
/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,5 +16,9 @@ public interface IMessageBus
/// <param name="dataProducer">The data producer.</param>
/// <param name="data">The data to be published.</param>
/// <returns>A task representing the asynchronous operation.</returns>
/// <remarks>
/// The data is not dispatched to consumers whose <see cref="Microsoft.Testing.Platform.Extensions.IExtension.Uid"/> matches the
/// <paramref name="dataProducer"/>'s UID.
/// </remarks>
Task PublishAsync(IDataProducer dataProducer, IData data);
}