Type Alias CallbackChan 

pub type CallbackChan = Sender<Status>;

Channel for sending acknowledgment status back to input modules.

Input modules can optionally provide a callback channel when emitting messages. The runtime will send a Status through this channel once all processing and output operations for the message (and any derived messages) are complete.

This enables input modules to implement at-least-once delivery semantics by only acknowledging messages after successful processing.

Example

use fiddler::{new_callback_chan, Status};

let (tx, rx) = new_callback_chan();
// ... emit message with tx as callback ...
// Later, check the result:
// match rx.await {
//     Ok(Status::Processed) => println!("Success"),
//     Ok(Status::Errored(errs)) => println!("Failed: {:?}", errs),
//     Err(_) => println!("Channel closed"),
// }

Aliased Type

pub struct CallbackChan { /* private fields */ }