rx
            .take_while(|command| match command {
                Command::AuditEntry(_) => Ok(true),
                Command::Shutdown => Ok(false),
            })
            .filter_map(|command| match command {
                Command::AuditEntry(entry) => Some(entry),
                Command::Shutdown => None,
            })

    pub fn init(config: &AuditClientConfig) -> (Self, impl Future<Item = (), Error = AuditError>) {
        let (tx, rx) = mpsc::channel(0);
        let client = AuditClientApi { tx };
        let future_socket = UdpSocket::bind(&config.src_addr)
        let running = future_socket
            .and_then(move |socket| {
                rx
                    .take_while(|command| match command {
                         //
                    })
                    .filter_map(|command| match command {
                        //
                    })
                    .fold(socket, move |socket, entry| {
                         //
                    })
            })
        (client, running)
    }