nanocodex-agent 0.3.0

Owned OpenAI agent lifecycle for Nanocodex
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::{future::Future, sync::Arc};

use crate::{NanocodexError, Result};

pub(crate) type ServiceFactory<S> = Arc<dyn Fn() -> S + Send + Sync>;

pub(crate) trait AgentSend: Send {}

impl<T: Send> AgentSend for T {}

pub(crate) trait AgentFactory: Send + Sync {}

impl<T: Send + Sync> AgentFactory for T {}

pub(crate) fn spawn_driver<F>(driver: F) -> Result<()>
where
    F: Future<Output = ()> + Send + 'static,
{
    let runtime = tokio::runtime::Handle::try_current()
        .map_err(|_| NanocodexError::TokioRuntimeUnavailable)?;
    drop(runtime.spawn(driver));
    Ok(())
}