diff --git a/src/connector/src/source/base.rs b/src/connector/src/source/base.rs index 269cc4f037e95..a4996eabbf82e 100644 --- a/src/connector/src/source/base.rs +++ b/src/connector/src/source/base.rs @@ -316,6 +316,7 @@ pub fn extract_source_struct(info: &PbStreamSourceInfo) -> Result /// Stream of [`SourceMessage`]. pub type BoxSourceStream = BoxStream<'static, crate::error::ConnectorResult>>; +// Manually expand the trait alias to improve IDE experience. pub trait ChunkSourceStream: Stream> + Send + 'static {