rafaelcaricio/backie
rafaelcaricio/backie
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

fix examples (#94)

Browse source
This commit is contained in:
Ayrat Badykov 2022-09-18 16:05:26 +03:00 committed by GitHub
parent 7c0aa2fab9
commit 19598d63cb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 9 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
fang_examples/asynk/simple_async_worker/src/lib.rs
View file

@ -1,9 +1,9 @@
use fang::async_trait;
use fang::asynk::async_queue::AsyncQueueable;
use fang::asynk::async_runnable::Error;
use fang::serde::{Deserialize, Serialize};
use fang::typetag;
use fang::AsyncRunnable;
use fang::FangError;
use std::time::Duration;
#[derive(Serialize, Deserialize)]
@ -33,7 +33,7 @@ impl MyFailingTask {
#[async_trait]
#[typetag::serde]
impl AsyncRunnable for MyTask {
async fn run(&self, queue: &mut dyn AsyncQueueable) -> Result<(), Error> {
async fn run(&self, queue: &mut dyn AsyncQueueable) -> Result<(), FangError> {
let new_task = MyTask::new(self.number + 1);
queue
.insert_task(&new_task as &dyn AsyncRunnable)
@ -50,7 +50,7 @@ impl AsyncRunnable for MyTask {
#[async_trait]
#[typetag::serde]
impl AsyncRunnable for MyFailingTask {
async fn run(&self, queue: &mut dyn AsyncQueueable) -> Result<(), Error> {
async fn run(&self, queue: &mut dyn AsyncQueueable) -> Result<(), FangError> {
let new_task = MyFailingTask::new(self.number + 1);
queue
.insert_task(&new_task as &dyn AsyncRunnable)

4
fang_examples/asynk/simple_cron_async_worker/src/lib.rs
View file

@ -1,9 +1,9 @@
use fang::async_trait;
use fang::asynk::async_queue::AsyncQueueable;
use fang::asynk::async_runnable::Error;
use fang::serde::{Deserialize, Serialize};
use fang::typetag;
use fang::AsyncRunnable;
use fang::FangError;
use fang::Scheduled;
#[derive(Serialize, Deserialize)]
@ -13,7 +13,7 @@ pub struct MyCronTask {}
#[async_trait]
#[typetag::serde]
impl AsyncRunnable for MyCronTask {
async fn run(&self, _queue: &mut dyn AsyncQueueable) -> Result<(), Error> {
async fn run(&self, _queue: &mut dyn AsyncQueueable) -> Result<(), FangError> {
log::info!("CRON!!!!!!!!!!!!!!!",);
Ok(())

11
src/asynk/async_worker.rs
View file

@ -70,14 +70,9 @@ where
self.queue.fail_task(task, &error.description).await?;
}
},
RetentionMode::RemoveAll => match result {
Ok(_) => {
self.queue.remove_task(task.id).await?;
}
Err(_error) => {
self.queue.remove_task(task.id).await?;
}
},
RetentionMode::RemoveAll => {
self.queue.remove_task(task.id).await?;
}
RetentionMode::RemoveFinished => match result {
Ok(_) => {
self.queue.remove_task(task.id).await?;

5
src/blocking/worker.rs
View file

@ -133,10 +133,7 @@ where
}
RetentionMode::RemoveAll => {
match result {
Ok(_) => self.queue.remove_task(task.id).unwrap(),
Err(_error) => self.queue.remove_task(task.id).unwrap(),
};
self.queue.remove_task(task.id).unwrap();
}
RetentionMode::RemoveFinished => match result {