pub struct Workflow<I> { /* private fields */ }Expand description
Workflow.
Implementations§
Source§impl<I> Workflow<I>where
I: Debug,
impl<I> Workflow<I>where
I: Debug,
Sourcepub fn new(id: usize, workspace: WorkspaceRef<I>) -> Self
pub fn new(id: usize, workspace: WorkspaceRef<I>) -> Self
Creates a new workflow.
Sourcepub fn add_source<T>(&self) -> Stream<I, T>where
T: Any,
pub fn add_source<T>(&self) -> Stream<I, T>where
T: Any,
Adds a source stream.
Sourcepub fn add_operator<S, O, T, U>(&self, from: S, operator: O) -> Stream<I, U>
pub fn add_operator<S, O, T, U>(&self, from: S, operator: O) -> Stream<I, U>
Adds an operator to the workflow.
Trait Implementations§
Auto Trait Implementations§
impl<I> Freeze for Workflow<I>
impl<I> !RefUnwindSafe for Workflow<I>
impl<I> !Send for Workflow<I>
impl<I> !Sync for Workflow<I>
impl<I> Unpin for Workflow<I>
impl<I> !UnwindSafe for Workflow<I>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T, E> IntoReport<T, E> for Twhere
E: Error,
impl<T, E> IntoReport<T, E> for Twhere
E: Error,
Source§fn into_report(self) -> Result<Report<T>, E>
fn into_report(self) -> Result<Report<T>, E>
Creates a report from a value T and wraps it in a result.
§Examples
use std::io::Error;
use zrx_diagnostic::report::IntoReport;
// Define function returning a value
fn f() -> impl IntoReport<i32, Error> {
42
}
// Invoke function and create report
let res = f().into_report();