pub fn new(logger: &Logger, postgres_url: String, channel_name: SafeChannelName) -> Self {
        // Listen to Postgres notifications in a worker thread
        let (receiver, worker_handle, terminate_worker, worker_barrier) =
            Self::listen(logger, postgres_url, channel_name);

        NotificationListener {
            output: Some(receiver),
            worker_handle: Some(worker_handle),
            terminate_worker,
            worker_barrier,
            started: false,
        }
    }
/// Connect to the specified database and listen for Postgres notifications on the specified
/// channel.
///
/// Must call `.start()` to begin receiving notifications.
Connect to the specified database and listen for Postgres notifications on the specified
channel.

Must call `.start()` to begin receiving notifications.
Connect to the specified database and listen for Postgres notifications on the specified channel . Must call ` . start () ` to begin receiving notifications .
pub fn new(logger: &Logger, postgres_url: String, channel_name: SafeChannelName) -> Self {
        // Listen to Postgres notifications in a worker thread
        let (receiver, worker_handle, terminate_worker, worker_barrier) =
            Self::listen(logger, postgres_url, channel_name);
        NotificationListener {
            output: Some(receiver),
            worker_handle: Some(worker_handle),
            terminate_worker,
            worker_barrier,
            started: false,
        }
    }
pub fn new ( logger : & Logger , postgres_url : String , channel_name : SafeChannelName ) -> Self { // Listen to Postgres notifications in a worker thread let ( receiver , worker_handle , terminate_worker , worker_barrier ) = Self :: listen ( logger , postgres_url , channel_name ) ; NotificationListener { output : Some ( receiver ) , worker_handle : Some ( worker_handle ) , terminate_worker , worker_barrier , started : false , } }
Connect to the specified database and listen for Postgres notifications on the specified
channel.
Connect to the specified database and listen for Postgres notifications on the specified channel .
logger
&Logger
postgres_url
String
channel_name
SafeChannelName
logger
&Logger
postgres_url
String
channel_name
SafeChannelName