Enum ApiBody

pub enum ApiBody {
    Stream(Box<dyn Stream<Item = Result<Bytes, Box<dyn Display + Send + Sync>>> + Send + Unpin>),
    Native(Value),
}

Variants

Stream(Box<dyn Stream<Item = Result<Bytes, Box<dyn Display + Send + Sync>>> + Send + Unpin>)

Native(Value)

Implementations

impl ApiBody

pub fn from_stream<S, E>(stream: S) -> Self

where S: Stream<Item = Result<Bytes, E>> + Unpin + Send + 'static, E: Display + Send + Sync + 'static,

pub fn from_value(value: Value) -> Self

pub fn is_native(&self) -> bool

pub async fn stream(self, max: Option<Bytesize>) -> Result<Vec<u8>, Error>

pub async fn process( self, ctx: &InvocationContext, invocation: &ApiInvocation, ) -> Result<Value, Error>