mirror of
https://github.com/migatu/conjurer.git
synced 2026-07-17 15:22:10 +00:00
Test
This commit is contained in:
@@ -107,7 +107,8 @@ class SRBuffer(voice_recv.AudioSink):
|
|||||||
self.wavewriter[str(user.id)][0].writeframes(data.pcm)
|
self.wavewriter[str(user.id)][0].writeframes(data.pcm)
|
||||||
self.wavewriter[str(user.id)][1] = time.time_ns() #time from last write
|
self.wavewriter[str(user.id)][1] = time.time_ns() #time from last write
|
||||||
self.wavewriter[str(user.id)][3] = True #data written in last iter
|
self.wavewriter[str(user.id)][3] = True #data written in last iter
|
||||||
self.wavewriter[str(user.id)][4] = True #data in buffer
|
self.wavewriter[str(user.id)][4] = True #data in buff
|
||||||
|
time.sleep(0.001)
|
||||||
|
|
||||||
def cleanup(self) -> None:
|
def cleanup(self) -> None:
|
||||||
try:
|
try:
|
||||||
@@ -188,7 +189,7 @@ class Transcriber(commands.Cog):
|
|||||||
async def stop(self, ctx):
|
async def stop(self, ctx):
|
||||||
self.check_data.stop()
|
self.check_data.stop()
|
||||||
stop_token = CommunicationObject("STOP",None,None)
|
stop_token = CommunicationObject("STOP",None,None)
|
||||||
logger.info("Item added to queue %s %s", self.queue, stop_token)
|
logger.info("Item added to queue %s %s", self.comm_queue, stop_token)
|
||||||
|
|
||||||
self.comm_queue.put(stop_token)
|
self.comm_queue.put(stop_token)
|
||||||
await ctx.voice_client.disconnect()
|
await ctx.voice_client.disconnect()
|
||||||
|
|||||||
Reference in New Issue
Block a user