Struct Pipe

pub struct Pipe<A: Statement + Send, B: StatementWithInput<Input = A::Output> + Send> { /* private fields */ }

Link two Statements and use the output of A as the input of B.

Trait Implementations

impl<A: Statement + Send, B: StatementWithInput<Input = A::Output> + Send> Statement for Pipe<A, B>

type Output = <B as StatementWithInput>::Output

Output of this statement.

fn execute<S: SqlExecutor>( self, connection: &S, ) -> Result<Self::Output, S::Error>

Execute the statement and return the result.

fn execute_mut<S: SqlExecutorMut>( self, connection: &mut S, ) -> Result<Self::Output, S::Error>

Execute the statement and return the result.

async fn execute_async<S: SqlExecutorAsync>( self, connection: &mut S, ) -> Result<Self::Output, S::Error>

Execute the statement and return the result.

fn then<Q: Statement>(self, statement: Q) -> Then<Self, Q>

where Self: Sized,

If this statement succeeds, then execute the next statement.

fn pipe<Q: StatementWithInput<Input = Self::Output> + Send>( self, statement: Q, ) -> Pipe<Self, Q>

where Self: Sized,

if the current statement succeeds, then execute the next statement with output of the current Statement.

fn spanned(self, span: Span) -> TracedStatement<Self>

where Self: Sized,

Instrument the current statement with the given Span

fn spanned_in_current(self) -> TracedStatement<Self>

where Self: Sized,

Instrument the current statement with currently active Span