如何检测tokio-serde库中tokio sink项中的tcp断开连接？

use tokio::sync::mpsc;
use tokio::net::TcpStream;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio_serde::formats::SymmetricalBincode;
use tokio_serde::SymmetricallyFramed;

async fn handle_connection(stream: TcpStream) {
    // 创建一个SymmetricallyFramed对象，用于序列化和反序列化数据
    let (mut sink, mut stream) = SymmetricallyFramed::new(stream, SymmetricalBincode::<String>::default());

    // 循环读取数据
    loop {
        // 读取数据
        let data: Result<String, _> = stream.try_next().await;

        match data {
            Ok(Some(message)) => {
                // 处理接收到的消息
                println!("Received message: {}", message);
            }
            Ok(None) => {
                // TCP连接已断开
                println!("TCP connection closed");
                break;
            }
            Err(err) => {
                // 发生错误
                println!("Error: {}", err);
                break;
            }
        }
    }
}

#[tokio::main]
async fn main() {
    // 建立tcp连接
    let address = "127.0.0.1:8080";
    let stream = TcpStream::connect(address).await.unwrap();

    // 处理tcp连接
    handle_connection(stream).await;
}