pub fn breakable_logic(config: Config, brk: Arc<AtomicBool>) -> JoinHandle<Result<(), String>> {
    thread::Builder::new()
        .name(String::from("Receiver"))
        .spawn(move || {
            receiver(config, brk)
        }).expect("Can't create thread for the broker")
}
/// Creates the receiver.
/// `brk` parameter should be set to `true` when the receiver should terminate.
/// Returns handler to join the thread.
Creates the receiver.
`brk` parameter should be set to `true` when the receiver should terminate.
Returns handler to join the thread.
Creates the receiver . ` brk ` parameter should be set to ` true ` when the receiver should terminate . Returns handler to join the thread .
pub fn breakable_logic(config: Config, brk: Arc<AtomicBool>) -> JoinHandle<Result<(), String>> {
    thread::Builder::new()
        .name(String::from("Receiver"))
        .spawn(move || {
            receiver(config, brk)
        }).expect("Can't create thread for the broker")
}
pub fn breakable_logic ( config : Config , brk : Arc < AtomicBool > ) -> JoinHandle < Result < ( ) , String > > { thread :: Builder :: new ( ) . name ( String :: from ( " " ) ) . spawn ( move | | { receiver ( config , brk ) } ) . expect ( " " ) }
Creates the receiver.
Creates the receiver .
config
Config
brk
Arc<AtomicBool>
config
Config
brk
Arc<AtomicBool>