perspective 3.7.1-alpha1

// ┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
// ┃ ██████ ██████ ██████       █      █      █      █      █ █▄  ▀███ █       ┃
// ┃ ▄▄▄▄▄█ █▄▄▄▄▄ ▄▄▄▄▄█  ▀▀▀▀▀█▀▀▀▀▀ █ ▀▀▀▀▀█ ████████▌▐███ ███▄  ▀█ █ ▀▀▀▀▀ ┃
// ┃ █▀▀▀▀▀ █▀▀▀▀▀ █▀██▀▀ ▄▄▄▄▄ █ ▄▄▄▄▄█ ▄▄▄▄▄█ ████████▌▐███ █████▄   █ ▄▄▄▄▄ ┃
// ┃ █      ██████ █  ▀█▄       █ ██████      █      ███▌▐███ ███████▄ █       ┃
// ┣━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┫
// ┃ 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). ┃
// ┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛

// 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(())
}