perspective 4.4.1

// ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
// ┃ ██████ ██████ ██████       █      █      █      █      █ █▄  ▀███ █       ┃
// ┃ ▄▄▄▄▄█ █▄▄▄▄▄ ▄▄▄▄▄█  ▀▀▀▀▀█▀▀▀▀▀ █ ▀▀▀▀▀█ ████████▌▐███ ███▄  ▀█ █ ▀▀▀▀▀ ┃
// ┃ █▀▀▀▀▀ █▀▀▀▀▀ █▀██▀▀ ▄▄▄▄▄ █ ▄▄▄▄▄█ ▄▄▄▄▄█ ████████▌▐███ █████▄   █ ▄▄▄▄▄ ┃
// ┃ █      ██████ █  ▀█▄       █ ██████      █      ███▌▐███ ███████▄ █       ┃
// ┣━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┫
// ┃ Copyright (c) 2017, the Perspective Authors.                              ┃
// ┃ ╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌╌ ┃
// ┃ This file is part of the Perspective library, distributed under the terms ┃
// ┃ of the [Apache License 2.0](https://www.apache.org/licenses/LICENSE-2.0). ┃
// ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛

#[cfg(feature = "axum-ws")]
mod internal {
    // use tokio::sync::Mutex;
    use std::error::Error;
    use std::sync::Arc;

    use perspective_client::{OnUpdateOptions, TableInitOptions, UpdateData, UpdateOptions};
    use perspective_server::LocalClient;
    use tokio::sync::Mutex;

    #[tokio::test]
    async fn test_two_sync_clients_receive_messages_on_update() -> Result<(), Box<dyn Error>> {
        let server = perspective::server::Server::new(None);
        let client1 = LocalClient::new(&server);
        let client2 = LocalClient::new(&server);
        let table = client1
            .table(
                UpdateData::Csv("x,y\n1,2\n3,4".to_owned()).into(),
                TableInitOptions {
                    name: Some("Table1".to_owned()),
                    index: None,
                    limit: None,
                    format: None,
                },
            )
            .await?;

        let table2 = client2.open_table("Table1".to_owned()).await?;
        let view = table2.view(None).await?;
        let result = Arc::new(Mutex::new(false));
        let _sub = view
            .on_update(
                {
                    let result = result.clone();
                    move |_| {
                        let result = result.clone();
                        async move { *result.lock().await = true }
                    }
                },
                OnUpdateOptions::default(),
            )
            .await?;

        table
            .update(
                UpdateData::Csv("x,y\n5,6".to_owned()),
                UpdateOptions::default(),
            )
            .await?;

        assert!(*result.lock().await);
        Ok(())
    }
}