This is pythonic high-level libtorrent API, inspired on the for-humans trend set by Kenneth Reitz (https://github.com/not-kennethreitz).
TorrentStream is centered around the principle of streaming a torrent (sequential download, buffering and playing).
TorrentStream exposes a CLI command, intended as an example usage.
Torrent objects are context managers that can clean up torrent content after you finish using them.
add_torrent method of a TorrentSession returns a Torrent object, thus can be used directly as a context manager.
async def stream_torrent(hash_torrent): session = TorrentSession() # By default this will cleanup torrent contents after playing with session.add_torrent(magnet_link=hash_torrent, remove_after=True) as torrent: # Force sequential mode torrent.sequential(True) # Wait for torrent to be started await torrent.wait_for('started') # Get first match of a media file try: media = next(a for a in torrent if a.is_media and not 'sample' in a.path.lower()) except StopIteration: raise Exception('Could not find a playable source') with timeout(5 * 60): # Abort if we can't fill 5% in 5 minutes await media.wait_for_completion(5) return await asyncio.gather(media.wait_for_completion(100), media.launch())