Method ReceiveInternalAsync
ReceiveInternalAsync(string, string?, ReadOnlySequence<byte>?, ReadOnlySequence<byte>)
Invoked when a MSG or HMSG arrives for the subscription.
protected abstract ValueTask ReceiveInternalAsync(string subject, string? replyTo, ReadOnlySequence<byte>? headersBuffer, ReadOnlySequence<byte> payloadBuffer)
Parameters
subject
stringSubject received for this subscription. This might not be the subject you subscribed to especially when using wildcards. For example, if you subscribed to events.* you may receive events.open.
replyTo
stringSubject the sender wants you to send messages back to it.
headersBuffer
ReadOnlySequence<byte>?Raw headers bytes. You can use NatsConnectionNatsHeaderParser to decode them.
payloadBuffer
ReadOnlySequence<byte>Raw payload bytes.