Function process_bmp_message

pub async fn process_bmp_message<T: StateStore>(
    state: Option<AsyncState<T>>,
    tx: Sender<Update>,
    socket: SocketAddr,
    bytes: &mut Bytes,
) -> Result<()>