Interface IStreamingTransport

Namespace

AnyProtocol.Protocol.Abstraction

Assembly

AnyProtocol.Protocol.Abstraction.dll

Defines the capability to perform native streaming operations.

public interface IStreamingTransport : IMessagingProtocol, IAsyncDisposable

Inherited Members

IMessagingProtocol.Capabilities

IMessagingProtocol.Semantics

IAsyncDisposable.DisposeAsync()

Methods

StreamAsync(string, TransportEnvelope, CancellationToken)

Sends a request and asynchronously yields the streamed response items.

IAsyncEnumerable<TransportEnvelope> StreamAsync(string channel, TransportEnvelope request, CancellationToken cancellationToken = default)

Parameters

channel string

The logical message channel.

request TransportEnvelope

The request to process.

cancellationToken CancellationToken

The token used to cancel the operation.

Returns

IAsyncEnumerable<TransportEnvelope>

An asynchronous sequence of response envelopes.