Commands and queries share CommandMessage/QueryMessage with async streaming helpers for workers.

Commands

Task<CommandResponse> SendCommandAsync(CommandMessage message, CancellationToken ct = default);

CommandMessage fields:

Property	Type	Required	Description
`Channel`	`string`	Yes	Target channel
`Body`	`ReadOnlyMemory<byte>`	Conditional	Payload
`Metadata`	`string?`	Conditional	Metadata
`TimeoutInSeconds`	`int?`	No	RPC timeout in seconds; falls back to client default
`Tags`	`Dictionary<string, string>?`	No	Tags

IAsyncEnumerable<CommandReceived> SubscribeToCommandsAsync(
    CommandsSubscription subscription, CancellationToken ct = default);

await client.SendCommandResponseAsync(CommandResponse response, CancellationToken ct = default);

Queries

Task<QueryResponse> SendQueryAsync(QueryMessage message, CancellationToken ct = default);

QueryMessage extends CommandMessage with:

Property	Type	Description
`CacheKey`	`string?`	Cache key
`CacheTtlSeconds`	`int?`	Cache TTL in seconds

IAsyncEnumerable<QueryReceived> SubscribeToQueriesAsync(
    QueriesSubscription subscription, CancellationToken ct = default);

await client.SendQueryResponseAsync(QueryResponse response, CancellationToken ct = default);

Rpc.cs

var response = await client.SendCommandAsync(new CommandMessage
{
    Channel = "svc.commands",
    Body = payload,
    TimeoutInSeconds = 5,
});