schrottkatze/iowo
0
0
Fork 0
mirror of https://forge.katzen.cafe/katzen-cafe/iowo.git synced 2026-01-16 16:43:05 +01:00
Code Issues Projects Releases Packages Wiki Activity

prowocessing: apply most basic reviews

Browse source
This commit is contained in:
Schrottkatze 2024-02-23 12:03:46 +01:00
commit ddc1f935c6
No known key found for this signature in database
7 changed files with 48 additions and 43 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -4,7 +4,7 @@ use core::panic;
use crate::experimental::trait_based::{
data::{
io::{Inputs, Outputs},
raw::Data,
raw::DataRef,
},
element::{DataType, ElementSignature, PipelineElement},
};
@ -14,7 +14,7 @@ pub struct Add(pub i32);
impl PipelineElement for Add {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [Data::Int(i0), Data::Int(i1), ..] = input.inner()[..] {
if let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] {
(i0 + i1).into()
} else {
panic!("Invalid data passed")
@ -35,7 +35,7 @@ pub struct Subtract(pub i32);
impl PipelineElement for Subtract {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [Data::Int(i0), Data::Int(i1), ..] = input.inner()[..] {
if let [DataRef::Int(i0), DataRef::Int(i1), ..] = input.inner()[..] {
(i0 + i1).into()
} else {
panic!("Invalid data passed")
@ -56,7 +56,7 @@ pub struct Stringify;
impl PipelineElement for Stringify {
fn runner(&self) -> fn(&Inputs) -> Outputs {
|input| {
if let [Data::Int(int), ..] = input.inner()[..] {
if let [DataRef::Int(int), ..] = input.inner()[..] {
int.to_string().into()
} else {
panic!("Invalid data passed")