Bug: websockets Rust SDK doesn't error on large queries

[AlexFrid]

Describe the bug

when doing a select * from a table with 1m+ records, I get the error
Error: Api(InternalError("receiving on a closed channel")

With this error in the logs
WebSocket error: Error { inner: Io(Os { code: 32, kind: BrokenPipe, message: "Broken pipe" }) }

Steps to reproduce

Run this code on large table, 1m+ records

use surrealdb::engine::remote::ws::Ws;
use surrealdb::opt::auth::Root;
use surrealdb::Surreal;

#[tokio::main]
async fn main() -> surrealdb::Result<()> {
    // Connect to the server
    let db = Surreal::new::<Ws>("127.0.0.1:8000").await?;

    // Signin as a namespace, database, or root user
    db.signin(Root {
        username: "root",
        password: "root",
    })
    .await?;

    // Select a specific namespace / database
    db.use_ns("test").use_db("test").await?;

    // Perform a custom advanced query
    let groups = db
        .query("SELECT * from person")
        .await?;
    println!("{:#?}", groups);

    Ok(())
}

Expected behaviour

Ideally return the data, alternatively a more descriptive error explaining why it didn't work.

SurrealDB version

1.0.0+20230913.54aedcd for macos on aarch64

Contact Details

alexander.fridriksson@surrealdb.com

Is there an existing issue for this?

• I have searched the existing issues

Code of Conduct

• I agree to follow this project's Code of Conduct