C# — Transport API

Transport APIs live in Nnrp.Core, Nnrp.Transport.Tcp, Nnrp.Transport.Quic, and Nnrp.NativeBridge. Application code usually picks one of two paths:

1. Use NnrpTcpMessageTransport directly when the app already knows it wants TCP.
2. Use the native bridge host surfaces plus the TCP/QUIC runtime packages when the app wants Rust-backed connection, session, submit/result, cancellation, and control paths.

Imports

using Nnrp.Core;
using Nnrp.Transport.Tcp;
using Nnrp.Transport.Quic;
using Nnrp.NativeBridge;

NnrpTcpMessageTransport.ConnectAsync

Opens a TCP connection and returns a framed NNRP transport.

Parameter	Type	Required	Values / Range	Description
host	string	Yes	Non-empty hostname or IP	Remote host.
port	int	Yes	1..65535	Remote TCP port.
cancellationToken	CancellationToken	No	Defaults to default	Cancels connect.

Returns	Throws
ValueTask<NnrpTcpMessageTransport>	Argument, connect, or cancellation errors.

await using var transport = await NnrpTcpMessageTransport.ConnectAsync("127.0.0.1", 4433, ct);

INnrpMessageTransport.SendAsync

Sends one framed message.

Parameter	Type	Required	Values / Range	Description
message	NnrpFramedMessage	Yes	Valid framed message	Message to write.
cancellationToken	CancellationToken	Yes	Any token	Cancels write.

Returns	Throws
ValueTask	Transport, disposal, or cancellation errors.

await transport.SendAsync(message, ct);

INnrpMessageTransport.ReceiveAsync

Receives one framed message.

Parameter	Type	Required	Values / Range	Description
cancellationToken	CancellationToken	Yes	Any token	Cancels receive.

Returns	Throws
ValueTask<NnrpFramedMessage>	Transport, malformed header, disposal, or cancellation errors.

var message = await transport.ReceiveAsync(ct);

Native Runtime Transport Providers

Nnrp.Transport.Tcp and Nnrp.Transport.Quic each expose a provider and runtime helper that map the package boundary to the Rust native transport slot. Use them with the native bridge host facades described in Client.

Type	Purpose
NnrpNativeTcpTransportProvider	TCP provider identity for native runtime selection.
NnrpNativeQuicTransportProvider	QUIC provider identity for native runtime selection.
NnrpNativeTcpRuntime	Opens TCP-backed session, connection, and server hosts.
NnrpNativeQuicRuntime	Opens QUIC-backed session, connection, and server hosts.

using var host = NnrpNativeTcpRuntime.OpenConnectionHost(
    new NnrpNativeTcpRuntimeConnectionHostOptions(connectionId: 1, connectionGeneration: 1));

Core Transport Types

INnrpMessageSender

Method	Parameter	Returns	Description
SendAsync	NnrpFramedMessage, CancellationToken	ValueTask	Writes one framed message.

INnrpMessageReceiver

Method	Parameter	Returns	Description
ReceiveAsync	CancellationToken	ValueTask<NnrpFramedMessage>	Reads one framed message.

INnrpMessageTransport

Combines INnrpMessageSender and INnrpMessageReceiver.

INnrpTransportIdentity

Property	Type	Description
TransportId	TransportId	Active NNRP transport binding.

Common Pitfalls

WARNING

1. NnrpTcpMessageTransport uses NNRP header lengths for framing; do not add an extra length prefix.
2. SendAsync and ReceiveAsync have separate internal gates, but application-level request ordering is still your responsibility.
3. Dispose transports with await using or DisposeAsync.
4. Use NnrpNativeTcpRuntime or NnrpNativeQuicRuntime for Rust-backed runtime paths; keep NnrpTcpMessageTransport for low-level TCP framing tests and diagnostics. :::