fetcher 0.15.3

Data automation and pipelining framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/.
 */

//! This test checks that spawning non-send jobs works as expected when feature "send" is not enabled

#[cfg(feature = "send")]
#[test]
#[ignore = "this test runs only when feature send is off"]
fn non_send_jobs() {}

#[cfg(not(feature = "send"))]
#[tokio::test(flavor = "current_thread")]
async fn non_send_jobs() {
	use std::{cell::Cell, rc::Rc};

	use fetcher::{
		Task,
		actions::transform_fn,
		job::{Job, error_handling::Forward, trigger},
	};
	use tokio::{join, task::LocalSet};

	LocalSet::new()
		.run_until(async {
			let rc = Rc::new(Cell::new(0));

			let task = Task::<(), _, _>::builder("task")
				.action(transform_fn(async |entry| {
					#[cfg(feature = "nightly")]
					rc.update(|x| x + 1);
					#[cfg(not(feature = "nightly"))]
					rc.set(rc.get() + 1);
					entry
				}))
				.build_without_replies();

			let mut job1 = Job::builder("job1")
				.tasks(task.clone())
				.trigger(trigger::Never)
				.error_handling(Forward)
				.cancel_token(None)
				.build();

			let mut job2 = Job::builder("job2")
				.tasks(task)
				.trigger(trigger::Never)
				.error_handling(Forward)
				.cancel_token(None)
				.build();

			let _res = join!(job1.run(), job2.run());

			assert_eq!(rc.get(), 2);
		})
		.await;
}