Struct NotifyChannel 

pub struct NotifyChannel<T> { /* private fields */ }

Typed handle to a single PostgreSQL NOTIFY channel.

T is the JSON payload shape. Construct one per channel as a const-ish value (name is &'static str) and reuse it everywhere that channel is touched, so publish and subscribe sites can never disagree on the shape.

Implementations

impl<T> NotifyChannel<T>

pub const fn new(name: &'static str) -> Self

Create a typed channel handle. name is the PostgreSQL channel identifier passed to pg_notify and LISTEN; it must be a valid SQL identifier (the framework uses snake_case forge_* names).

pub const fn name(&self) -> &'static str

PostgreSQL channel name.

impl<T> NotifyChannel<T>

where T: Serialize,

pub async fn publish<'e, E>(&self, executor: E, payload: &T) -> Result<()>

where E: PgExecutor<'e>,

Publish payload on this channel.

Errors:

• ForgeError::Serialization if serde_json::to_string(payload) fails.
• ForgeError::InvalidArgument if the serialized payload exceeds MAX_PAYLOAD_BYTES. Use the change-log fallback for larger bodies.
• ForgeError::Database if the underlying SELECT pg_notify(...) fails (transaction rolled back, connection dropped, etc.).

impl<T> NotifyChannel<T>

where T: DeserializeOwned + Send + 'static,

pub async fn subscribe( &self, listener: PgListener, ) -> Result<impl Stream<Item = T>>

Subscribe to this channel and return a stream of decoded payloads.

listener is consumed; the caller surrenders the connection to the stream for the duration of the subscription. Notifications whose payload fails JSON decoding are logged and skipped, so a malformed publish from one peer cannot tear down a long-running subscriber. Errors from the underlying recv (connection dropped, etc.) end the stream; the caller decides whether to reconnect.