LiveChatAsync

LiveChatAsync object

• fetches chat data and stores them in buffer with aiohttp on asyncio context.
• responds to user inquiries of get().
• invokes callback function with processed chat data.
• can replay archived chat data.

Usage

from pytchat import LiveChatAsync
import asyncio

async def main():
  chat = LiveChatAsync("G1w62uEMZ74", callback = func)
  while chat.is_alive():
    await asyncio.sleep(3)
    #other background operation.

#callback function is automatically called periodically.
async def func(data):
  for c in data.items:
    print(f"{c.datetime} [{c.author.name}]-{c.message} {c.amountString}")
    await data.tick_async()

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

#constructor params

name	type	required	remarks	default value
video_id	str	*	ID of youtube video.	-
processor	ChatPrcessor			DefaultProcessor
buffer	Buffer		buffer of chat data fetched background.	Buffer(maxsize=20)
interruptable	bool			True
callback	func		function called from _listen() periodically.	None
done_callback	func		function called when listener ends.	None
exception_handler	func		function called when exceptions occur.	None
direct_mode	bool		If True, invoke specified callback function without using buffer.	False
seektime	int		start position of fetching chat (seconds). This option is valid for archived chat only. If negative value, fetches chatdata which is posted before start broadcasting.	0
force_replay	bool		force to fetch archived chat data, even if specified video is live.	False

await get()

description	return value
Get processed chat data from buffer.	processed chat data

is_alive()

description	return value
Check if livechat stream is alive.	bool

terminate()

description	return value
Terminate fetching livechat.	-