@@ -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) ]
407372mod tests {
0 commit comments