From cf1c06e632fc2204a1826e74159a6735155724cd Mon Sep 17 00:00:00 2001 From: Alex Clarke Date: Thu, 7 May 2026 13:47:30 -0600 Subject: [PATCH] fmt: reapplied formatting for the sse_transport module --- src/mcp/sse_transport.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/mcp/sse_transport.rs b/src/mcp/sse_transport.rs index bc19b74..13ff192 100644 --- a/src/mcp/sse_transport.rs +++ b/src/mcp/sse_transport.rs @@ -1,7 +1,8 @@ use anyhow::{Context, Result, anyhow}; use fmt::{Display, Formatter}; use futures_util::StreamExt; -use mpsc::{Receiver, Sender, channel, OwnedPermit}; +use mpsc::error::SendError; +use mpsc::{OwnedPermit, Receiver, Sender, channel}; use reqwest::Client; use reqwest::header::{HeaderMap, HeaderName, HeaderValue}; use reqwest_eventsource::{Event, EventSource}; @@ -12,7 +13,6 @@ use std::fmt; use std::future::Future; use std::pin::Pin; use std::task::Poll; -use mpsc::error::SendError; use tokio::sync::mpsc; use tokio::time::Duration; use url::Url; @@ -234,8 +234,7 @@ impl Display for SseSinkError { impl Error for SseSinkError {} -type ReserveOwned = - Pin, SendError<()>>> + Send>>; +type ReserveOwned = Pin, SendError<()>>> + Send>>; struct PollSender { tx: Sender,