Rest/Fn/Binary/Command/
Sequential.rs

1/// Asynchronously processes entries to generate summaries and outputs the
2/// results sequentially.
3///
4/// This function performs the following steps:
5/// 1. Filters and processes the provided entries based on the given pattern and
6///    separator.
7/// 2. Spawns asynchronous tasks to generate summaries for each entry.
8/// 3. Collects the results and outputs them.
9///
10/// # Argument
11///
12/// * `Option` - A struct containing the following fields:
13///   - `Entry`: A vector of vectors, where each inner vector contains the
14///     components of a file path.
15///   - `Separator`: A character used to join the components of the file path.
16///   - `Pattern`: A string pattern to match against the last element of each
17///     entry.
18///
19/// # Example
20///
21/// ```rust
22/// let options = Option {
23
24/// 	Entry:vec![vec!["path".to_string(), "to".to_string(),
25/// "file.git".to_string()]],
26
27/// 	Separator:'/',
28
29/// 	Pattern:".git".to_string(),
30
31/// };
32
33/// Fn(options).await;
34
35/// ```
36/// 
37/// # Errors
38///
39/// This function will log errors if it fails to generate summaries or send
40/// results.
41pub async fn Fn(Option { Entry, Pattern, Separator, .. }:Option) {
42	let Queue = futures::future::join_all(
43		Entry
44			.into_iter()
45			.filter_map(|Entry| {
46				Entry
47					.last()
48					.filter(|Last| *Last == &Pattern)
49					.map(|_| Entry[0..Entry.len() - 1].join(&Separator.to_string()))
50			})
51			.map(|Entry| {
52				async move {
53					match crate::Fn::Build::Fn(&Entry).await {
54						Ok(Build) => Ok((Entry, format!("{:?}", Build))),
55
56						Err(_Error) => Err(format!("Error generating summary for {}: {}", Entry, _Error)),
57					}
58				}
59			}),
60	)
61	.await;
62
63	crate::Fn::Build::Group::Fn(Queue.into_iter().filter_map(Result::ok).collect::<Vec<_>>());
64}
65
66use crate::Struct::Binary::Command::Entry::Struct as Option;
Rest/Fn/Binary/Command/Sequential.rs

Rest/Fn/Binary/Command/
Sequential.rs
