| """Private loopback IPC; embeddings and user audio never leave this host.""" | |
| import uuid | |
| import httpx | |
| import numpy as np | |
| class DiarizationClient: | |
| def __init__(self): | |
| self.id=uuid.uuid4().hex;self.client=httpx.AsyncClient(base_url='http://127.0.0.1:8796',timeout=1.5) | |
| async def feed(self,audio): | |
| r=await self.client.post('/session/'+self.id,content=np.asarray(audio,'<f4').tobytes());r.raise_for_status();return r.json() | |
| async def close(self): | |
| try:await self.client.delete('/session/'+self.id) | |
| except httpx.HTTPError:pass | |
| await self.client.aclose() | |