Struct ChapterDownloadManager 

pub struct ChapterDownloadManager { /* private fields */ }

Implementations

impl ChapterDownloadManager

pub fn new(state: Addr<DownloadManagerState>) -> Self

Trait Implementations

impl Actor for ChapterDownloadManager

type Context = Context<ChapterDownloadManager>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

fn start(self) -> Addr<Self>

where Self: Actor<Context = Context<Self>>,

Start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn create<F>(f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self,

Start a new asynchronous actor given a Context.

impl Debug for ChapterDownloadManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for ChapterDownloadManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<A> GetManager<ChapterDownloadManager> for Addr<A>

where A: Actor + Handler<GetChapterDownloadManagerMessage>, <A as Actor>::Context: ToEnvelope<A, GetChapterDownloadManagerMessage>,

async fn get(&self) -> Result<Addr<Manager>, MailboxError>

impl Handler<ChapterDownloadMessage> for ChapterDownloadManager

type Result = <ChapterDownloadMessage as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, msg: ChapterDownloadMessage, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<DropSingleTaskMessage> for ChapterDownloadManager

type Result = <DropSingleTaskMessage as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, msg: DropSingleTaskMessage, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetManagerStateMessage> for ChapterDownloadManager

type Result = <GetManagerStateMessage as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, _msg: GetManagerStateMessage, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetTaskMessage<ChapterDownloadTask>> for ChapterDownloadManager

type Result = <GetTaskMessage<ChapterDownloadTask> as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, msg: GetTaskMessage<ChapterDownloadTask>, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<GetTasksListMessage> for ChapterDownloadManager

type Result = <GetTasksListMessage as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, _msg: GetTasksListMessage, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<SubcribeToManagerMessage> for ChapterDownloadManager

type Result = <SubcribeToManagerMessage as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, _msg: SubcribeToManagerMessage, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl TaskManager for ChapterDownloadManager

type Task = ChapterDownloadTask

type DownloadMessage = ChapterDownloadMessage

fn state(&self) -> Addr<DownloadManagerState>

fn notify(&self) -> Arc<Notify>

fn tasks(&self) -> Vec<Addr<Self::Task>>

fn tasks_id(&self) -> Vec<Uuid>

fn new_task( &mut self, msg: Self::DownloadMessage, ctx: &mut Self::Context, ) -> Addr<Self::Task>

fn drop_task(&mut self, id: Uuid)

fn get_task(&self, id: Uuid) -> Option<Addr<Self::Task>>