#![allow(
unused_imports,
dead_code,
non_camel_case_types,
unused_variables,
clippy::all
)]
use super::super::agent::prompty::Prompty;
#[async_trait::async_trait]
pub trait Processor: Send + Sync {
async fn process(
&self,
agent: &Prompty,
response: &serde_json::Value,
) -> Result<serde_json::Value, Box<dyn std::error::Error + Send + Sync>>;
async fn process_stream(
&self,
stream: &serde_json::Value,
) -> Result<serde_json::Value, Box<dyn std::error::Error + Send + Sync>> {
Err("not supported".into())
}
}