fix new version issue

TommyCpp · TommyCpp · commit 898aab44de97 · 2024-05-05T20:43:06.000-07:00
diff --git a/opentelemetry-sdk/src/trace/span_processor.rs b/opentelemetry-sdk/src/trace/span_processor.rs
@@ -399,7 +399,7 @@ impl<R: RuntimeChannel> BatchSpanProcessorInternal<R> {
         })
     }
 
-    async fn run(mut self, mut messages: impl Stream<Item = BatchMessage> + Unpin + FusedStream) {
+    async fn run(mut self, mut messages: impl Unpin + FusedStream<Item = BatchMessage>) {
         loop {
             select! {
                 // FuturesUnordered implements Fuse intelligently such that it

Original file line number	Diff line number	Diff line change
`@@ -399,7 +399,7 @@ impl<R: RuntimeChannel> BatchSpanProcessorInternal<R> {`
`399`	`399`	`})`
`400`	`400`	`}`
`401`	`401`
`402`		`- async fn run(mut self, mut messages: impl Stream<Item = BatchMessage> + Unpin + FusedStream) {`
	`402`	`+ async fn run(mut self, mut messages: impl Unpin + FusedStream<Item = BatchMessage>) {`
`403`	`403`	`loop {`
`404`	`404`	`select! {`
`405`	`405`	`// FuturesUnordered implements Fuse intelligently such that it`