AI slop

Author: fulmicoton-dd

quickwit/quickwit-indexing/src/source/mod.rs

@@ -92,7 +92,7 @@ pub use source_sink::SourceSink;
 pub use pulsar_source::{PulsarSource, PulsarSourceFactory};
 #[cfg(feature = "sqs")]
 pub use queue_sources::sqs_queue;
-use quickwit_actors::{Actor, ActorContext, ActorExitStatus, DeferableReplyHandler, Handler, Mailbox};
+use quickwit_actors::{Actor, ActorContext, ActorExitStatus, Handler};
 use quickwit_common::metrics::{GaugeGuard, MEMORY_METRICS};
 use quickwit_common::pubsub::EventBroker;
 use quickwit_common::runtimes::RuntimeType;
@@ -118,7 +118,7 @@ pub use void_source::{VoidSource, VoidSourceFactory};
 
 use self::doc_file_reader::dir_and_filename;
 use self::stdin_source::StdinSourceFactory;
-use crate::models::{NewPublishLock, NewPublishToken, RawDocBatch};
+use crate::models::RawDocBatch;
 use crate::source::ingest::IngestSourceFactory;
 use crate::source::ingest_api_source::IngestApiSourceFactory;
 
@@ -318,15 +318,10 @@ pub struct SourceActor {
 }
 
 impl SourceActor {
-    pub fn new<A>(source: Box<dyn Source>, source_sink: Mailbox<A>) -> Self
-    where A: Actor
-            + DeferableReplyHandler<RawDocBatch>
-            + DeferableReplyHandler<NewPublishLock>
-            + DeferableReplyHandler<NewPublishToken>
-    {
+    pub fn new(source: Box<dyn Source>, source_sink: impl Into<SourceSink>) -> Self {
         SourceActor {
             source,
-            source_sink: SourceSink::new(source_sink),
+            source_sink: source_sink.into(),
         }
     }
 }

quickwit/quickwit-indexing/src/source/source_sink.rs

@@ -71,19 +71,15 @@ pub struct SourceSink {
     inner: Arc<dyn SourceSinkTrait>,
 }
 
-impl SourceSink {
-    /// Create a `SourceSink` from any actor mailbox whose actor implements
-    /// the required message handlers.
-    pub fn new<A>(mailbox: Mailbox<A>) -> Self
-    where A: Actor
-            + DeferableReplyHandler<RawDocBatch>
-            + DeferableReplyHandler<NewPublishLock>
-            + DeferableReplyHandler<NewPublishToken> {
+impl<T: SourceSinkTrait> From<T> for SourceSink {
+    fn from(source_sink: T) -> Self {
         Self {
-            inner: Arc::new(mailbox),
+            inner: Arc::new(source_sink),
         }
     }
+}
 
+impl SourceSink {
     /// Send a `RawDocBatch` to the processor.
     ///
     /// The source context's protect zone is held while the send is in flight,