pub async fn terminate(self) {
        self.snd.send(()).unwrap_or_else(|err| {
            error!(?err, "Failed to terminate the external event ingestion.");
        });
        self.external_drained
            .await
            .unwrap_or_else(|err| error!(?err, "Error waiting for external events to be drained."));
    }
/// Terminates external event ingestion. Buffered events will be drained. The returned future
/// will complete once all buffered external events have been drained.
Terminates external event ingestion. Buffered events will be drained. The returned future
will complete once all buffered external events have been drained.
Terminates external event ingestion . Buffered events will be drained . The returned future will complete once all buffered external events have been drained .
pub async fn terminate(self) {
        self.snd.send(()).unwrap_or_else(|err| {
            error!(?err, "Failed to terminate the external event ingestion.");
        });
        self.external_drained
            .await
            .unwrap_or_else(|err| error!(?err, "Error waiting for external events to be drained."));
    }
pub async fn terminate ( self ) { self . snd . send ( ( ) ) . unwrap_or_else ( | err | { error ! ( err " " ) ; } ) ; self . external_drained . await . unwrap_or_else ( | err | error ! ( err " " ) ) ; }
Terminates external event ingestion.
Terminates external event ingestion .
self
self