old_contents: import asyncio
  
  from cysystemd.async_reader import AsyncJournalReader
  from cysystemd.reader import JournalOpenMode
  
  
  async def main():
      reader = AsyncJournalReader()
      await reader.open(JournalOpenMode.SYSTEM)
      await reader.seek_tail()
  
      while await reader.wait():
          async for record in reader:
              print(record.data["MESSAGE"])
  
  
  if __name__ == "__main__":
      asyncio.run(main())
  
new_contents: import asyncio
  import json
  
  from cysystemd.async_reader import AsyncJournalReader
  from cysystemd.reader import JournalOpenMode
  
  
  async def main():
      reader = AsyncJournalReader()
      await reader.open(JournalOpenMode.SYSTEM)
      await reader.seek_tail()
  
      while await reader.wait():
          async for record in reader:
              print(json.dumps(record.data, indent=1, sort_keys=True))
  
  
  if __name__ == "__main__":
      asyncio.run(main())
  
subject: revert example