Trait tokio_openai::OpenAiStreamExt

pub trait OpenAiStreamExt: Stream<Item = Result<String>> + Sized {
    // Provided methods
    fn chars(
        self
    ) -> FlatMap<Self, Iter<IntoIter<Result<char, Error>>>, fn(_: Result<String>) -> Iter<IntoIter<Result<char, Error>>>> { ... }
    fn lines(self) -> ReceiverStream<Result<String>>
       where Self: Send + 'static { ... }
}

Provided Methods

fn chars( self ) -> FlatMap<Self, Iter<IntoIter<Result<char, Error>>>, fn(_: Result<String>) -> Iter<IntoIter<Result<char, Error>>>>

fn lines(self) -> ReceiverStream<Result<String>>where Self: Send + 'static,

Outputs a stream of Strings where each item is a line

Implementors

impl<T> OpenAiStreamExt for Twhere T: Stream<Item = Result<String>> + Sized,