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

use tokio::net::TcpStream;
use tokio_serde::{formats::Json, SymmetricallyFramed};
use futures::{SinkExt, StreamExt};
use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize, Debug)]
struct Message {
    content: String,
}

#[tokio::main]
async fn main() {
    // 假设已经建立了TCP连接
    let stream = TcpStream::connect("127.0.0.1:8080").await.unwrap();
    let transport = SymmetricallyFramed::new(stream, Json::<Message>::default());

    let (mut write, mut read) = transport.split();

    // 发送消息
    let message_to_send = Message {
        content: "Hello".to_string(),
    };
    if let Err(e) = write.send(message_to_send).await {
        eprintln!("Failed to send message: {:?}", e);
        // 这里可以处理连接断开的情况
        return;
    }

    // 接收消息
    while let Some(result) = read.next().await {
        match result {
            Ok(message) => println!("Received: {:?}", message),
            Err(e) => {
                eprintln!("Connection error: {:?}", e);
                // 连接断开，退出循环
                break;
            }
        }
    }
}