Skip to content

Commit 79632e9

Browse files
committed
chore(agent): remove ractor migrate logic
1 parent 1647958 commit 79632e9

File tree

1 file changed

+1
-36
lines changed

1 file changed

+1
-36
lines changed

crates/tap-agent/src/actor_migrate.rs

Lines changed: 1 addition & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -366,42 +366,7 @@ impl TaskRegistry {
366366
}
367367
}
368368

369-
/// Compatibility wrapper to make ractor ActorRef work with our abstraction
370-
#[cfg(any(test, feature = "test"))]
371-
pub mod compat {
372-
use super::*;
373-
use ractor::ActorRef;
374-
375-
/// Trait to unify ActorRef and TaskHandle APIs
376-
#[allow(dead_code)]
377-
pub trait MessageSender<T>: Clone + Send + Sync {
378-
/// Send a message to the target
379-
fn cast(&self, msg: T) -> impl Future<Output = Result<()>> + Send;
380-
/// Stop the target with optional reason
381-
fn stop(&self, reason: Option<String>);
382-
}
383-
384-
impl<T: Send + 'static> MessageSender<T> for TaskHandle<T> {
385-
async fn cast(&self, msg: T) -> Result<()> {
386-
TaskHandle::cast(self, msg).await
387-
}
388-
389-
fn stop(&self, reason: Option<String>) {
390-
TaskHandle::stop(self, reason)
391-
}
392-
}
393-
394-
impl<T: Send + 'static> MessageSender<T> for ActorRef<T> {
395-
async fn cast(&self, msg: T) -> Result<()> {
396-
ractor::ActorRef::cast(self, msg).map_err(|e| anyhow!("Actor error: {:?}", e))
397-
}
398-
399-
#[allow(unconditional_recursion)]
400-
fn stop(&self, _reason: Option<String>) {
401-
ractor::ActorRef::stop(self, _reason)
402-
}
403-
}
404-
}
369+
// Compatibility module removed - tokio migration complete! 🎉
405370

406371
#[cfg(test)]
407372
mod tests {

0 commit comments

Comments
 (0)