Skip to main content

execute_streaming_transform

Function execute_streaming_transform 

Source
pub async fn execute_streaming_transform<E: CommandExecutor>(
    executor: &E,
    request: Request,
    transform: Transform,
    agent_arguments: Option<&AgentArguments>,
) -> Result<E::Stream<Value>, E::Error>