schrottkatze/iowo
1
0
Fork 0
forked from katzen-cafe/iowo
Code Pull requests Activity

prowocessing: let-else refatoring as according to review

Browse source
This commit is contained in:
Schrottkatze 2024-02-23 12:11:35 +01:00
parent b7bc0366c2
commit 619b7acf94
Signed by: schrottkatze
SSH key fingerprint: SHA256:hXb3t1vINBFCiDCmhRABHX5ocdbLiKyCdKI4HK2Rbbc
2 changed files with 18 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

21
crates/prowocessing/src/experimental/trait_based/ops/num.rs
View file

@ -14,11 +14,10 @@ pub struct Add(pub i32);
impl PipelineElement for Add {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] {
(i0 + i1).into()
} else {
let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] else {
panic!("Invalid data passed")
}
};
(i0 + i1).into()
}
}
@ -35,11 +34,10 @@ pub struct Subtract(pub i32);
impl PipelineElement for Subtract {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] {
(i0 + i1).into()
} else {
let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] else {
panic!("Invalid data passed")
}
};
(i0 + i1).into()
}
}
@ -56,11 +54,10 @@ pub struct Stringify;
impl PipelineElement for Stringify {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [DataRef::Int(int), ..] = input.inner()[..] {
int.to_string().into()
} else {
let [DataRef::Int(int), ..] = input.inner()[..] else {
panic!("Invalid data passed")
}
};
int.to_string().into()
}
}