Struct SubprocessEmbedder 

pub struct SubprocessEmbedder { /* private fields */ }

Embedder that talks to a long-lived Python subprocess over stdin/stdout.

The subprocess must implement a simple line protocol:

• stdin: one text per line
• stdout: space-separated floats per line (same order)

Example Python server (embed_server.py):

import sys
from sentence_transformers import SentenceTransformer
model = SentenceTransformer("all-MiniLM-L6-v2")
for line in sys.stdin:
    vec = model.encode(line.strip()).tolist()
    print(" ".join(map(str, vec)), flush=True)

Implementations

impl SubprocessEmbedder

pub fn new(program: &str, args: &[&str]) -> Result<Self>

Spawn the subprocess. program is e.g. "python3", args is e.g. &["embed_server.py"].

Trait Implementations

impl Embedder for SubprocessEmbedder

fn embed(&self, text: &str) -> Result<Vec<f32>>

Embed a single text query, returning a normalised float vector.