Struct AndThen

pub struct AndThen<Op1, Op2> { /* private fields */ }

Trait Implementations

impl<Op1, Op2> Op for AndThen<Op1, Op2>

where Op1: TryOp, Op2: TryOp<Input = Op1::Output, Error = Op1::Error>,

type Input = <Op1 as TryOp>::Input

type Output = Result<<Op2 as TryOp>::Output, <Op1 as TryOp>::Error>

async fn call(&self, input: Self::Input) -> Self::Output

fn batch_call<I>( &self, n: usize, input: I, ) -> impl Future<Output = Vec<Self::Output>> + Send

where I: IntoIterator<Item = Self::Input> + Send, I::IntoIter: Send, Self: Sized,

Execute the current pipeline with the given inputs. n is the number of concurrent inputs that will be processed concurrently.

fn map<F, Input>(self, f: F) -> Sequential<Self, Map<F, Self::Output>>

where F: Fn(Self::Output) -> Input + Send + Sync, Input: Send + Sync, Self: Sized,

Chain a function f to the current op.

fn then<F, Fut>(self, f: F) -> Sequential<Self, Then<F, Fut::Output>>

where F: Fn(Self::Output) -> Fut + Send + Sync, Fut: Future + Send + Sync, Fut::Output: Send + Sync, Self: Sized,

Same as map but for asynchronous functions

fn chain<T>(self, op: T) -> Sequential<Self, T>

where T: Op<Input = Self::Output>, Self: Sized,

Chain an arbitrary operation to the current op.

fn lookup<I, Input>( self, index: I, n: usize, ) -> Sequential<Self, Lookup<I, Self::Output, Input>>

where I: VectorStoreIndex, Input: Send + Sync + for<'a> Deserialize<'a>, Self::Output: Into<String>, Self: Sized,

Chain a lookup operation to the current chain. The lookup operation expects the current chain to output a query string. The lookup operation will use the query to retrieve the top n documents from the index and return them with the query string.

fn prompt<P>(self, prompt: P) -> Sequential<Self, Prompt<P, Self::Output>>

where P: Prompt, Self::Output: Into<String>, Self: Sized,

Chain a prompt operation to the current chain. The prompt operation expects the current chain to output a string. The prompt operation will use the string to prompt the given agent (or any other type that implements the Prompt trait) and return the response.