From 1bfed0294f0783a5a36deb8e6e799e5e3abdd1c4 Mon Sep 17 00:00:00 2001 From: Kitaiti Makoto Date: Thu, 7 Jan 2021 04:56:25 +0900 Subject: [PATCH] Define SearchActor::init() --- plume-models/src/search/actor.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/plume-models/src/search/actor.rs b/plume-models/src/search/actor.rs index 9a939f93..881d0284 100644 --- a/plume-models/src/search/actor.rs +++ b/plume-models/src/search/actor.rs @@ -1,6 +1,6 @@ use super::Searcher; -use crate::{db_conn::DbPool, posts::PostEvent, POST_CHAN}; -use riker::actors::{Actor, ActorFactoryArgs, Context, Sender, Subscribe, Tell}; +use crate::{db_conn::DbPool, posts::PostEvent, ACTOR_SYS, POST_CHAN}; +use riker::actors::{Actor, ActorFactoryArgs, ActorRefFactory, Context, Sender, Subscribe, Tell}; use std::sync::Arc; use tracing::error; @@ -9,6 +9,12 @@ pub struct SearchActor { conn: DbPool, } +impl SearchActor { + pub fn init(searcher: Arc, conn: DbPool) { + ACTOR_SYS.actor_of_args::("search", (searcher, conn)).expect("Failed to initialize searcher actor"); + } +} + impl Actor for SearchActor { type Msg = PostEvent;