Skip to content

Commit 0b1e582

Browse files
committed
fix async runtime test
1 parent a8e74e5 commit 0b1e582

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

opentelemetry-sdk/src/trace/runtime_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ struct SpanCountExporter {
2525

2626
#[cfg(any(feature = "rt-tokio", feature = "rt-tokio-current-thread"))]
2727
impl SpanExporter for SpanCountExporter {
28-
async fn export(&mut self, batch: Vec<crate::trace::SpanData>) -> OTelSdkResult {
28+
async fn export(&self, batch: Vec<crate::trace::SpanData>) -> OTelSdkResult {
2929
self.span_count.fetch_add(batch.len(), Ordering::SeqCst);
3030
Ok(())
3131
}

opentelemetry-sdk/src/trace/span_processor_with_async_runtime.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -457,7 +457,7 @@ mod tests {
457457
D: Fn(Duration) -> DS + 'static + Send + Sync,
458458
DS: Future<Output = ()> + Send + Sync + 'static,
459459
{
460-
async fn export(&mut self, _batch: Vec<SpanData>) -> OTelSdkResult {
460+
async fn export(&self, _batch: Vec<SpanData>) -> OTelSdkResult {
461461
(self.delay_fn)(self.delay_for).await;
462462
Ok(())
463463
}

0 commit comments

Comments
 (0)