mirror of
https://github.com/migatu/conjurer.git
synced 2026-07-16 23:02:10 +00:00
Fix
This commit is contained in:
@@ -154,6 +154,7 @@ class Transcriber(commands.Cog):
|
|||||||
logger.info("Connected")
|
logger.info("Connected")
|
||||||
vc = await ctx.author.voice.channel.connect(cls=voice_recv.VoiceRecvClient)
|
vc = await ctx.author.voice.channel.connect(cls=voice_recv.VoiceRecvClient)
|
||||||
logger.info(self.bot.voice_clients)
|
logger.info(self.bot.voice_clients)
|
||||||
|
self.check_data.start()
|
||||||
self.worker.start()
|
self.worker.start()
|
||||||
vc.listen(self.wsink)
|
vc.listen(self.wsink)
|
||||||
|
|
||||||
@@ -199,13 +200,15 @@ class Transcriber(commands.Cog):
|
|||||||
@commands.command(name="stop_transcribe")
|
@commands.command(name="stop_transcribe")
|
||||||
async def stop(self, ctx):
|
async def stop(self, ctx):
|
||||||
self.check_data.stop()
|
self.check_data.stop()
|
||||||
self.worker.stop()
|
self.comm_queue.put("STOP")
|
||||||
await ctx.voice_client.disconnect()
|
await ctx.voice_client.disconnect()
|
||||||
|
|
||||||
def transcribe_output_queue(queue):
|
def transcribe_output_queue(queue):
|
||||||
logger.info("Worker start")
|
logger.info("Worker start")
|
||||||
while True:
|
while True:
|
||||||
queue.get()
|
item = queue.get()
|
||||||
|
if item == "STOP":
|
||||||
|
break
|
||||||
logger.info("PING")
|
logger.info("PING")
|
||||||
|
|
||||||
async def setup(bot):
|
async def setup(bot):
|
||||||
|
|||||||
Reference in New Issue
Block a user