Sanet.Transport.Channel 1.1.0

Sanet.Transport.Channel

System.Threading.Channels implementation of the Sanet.Transport abstractions.

👁 NuGet

Overview

Sanet.Transport.Channel provides an implementation of the ITransportPublisher interface using System.Threading.Channels, enabling high-performance message passing with back-pressure support.

Features

• High-performance message passing
• Producer-consumer patterns
• Thread-safe communication

Installation

dotnet add package Sanet.Transport.Channel

Or via the Package Manager Console:

Install-Package Sanet.Transport.Channel

Usage

// Create a Channel transport publisher
ITransportPublisher publisher = new ChannelTransportPublisher();

// Subscribe to messages
publisher.Subscribe(message => {
 Console.WriteLine($"Received message: {message.CommandType}");
 // Process the message
});

// Publish a message
publisher.PublishMessage(new TransportMessage {
 CommandType = "SomeCommand",
 SourceId = Guid.NewGuid(),
 Payload = "{\"key\": \"value\"}",
 Timestamp = DateTime.UtcNow
});

License

This project is licensed under the MIT License - see the LICENSE file for details.