Async subprocess pipelines and stream transports
Project description
Async subprocess pipelines and stream transports:
"""An example of using ``reel`` to play music.""" import trio from reel import Reel from reel.cmd import ffmpeg, sox async def main(): """Play some audio files through the speakers.""" cornell77 = ''.join([ 'http://archive.org/download/', 'gd1977-05-08.shure57.stevenson.29303', '.flac16/gd1977-05-08d02t{}.flac' ]) tracks = [ 'http://allotropic.com/static/out000.wav', 'http://allotropic.com/static/out001.wav', 'http://allotropic.com/static/out002.wav', 'http://allotropic.com/static/out003.wav', 'http://allotropic.com/static/out004.wav', 'http://allotropic.com/static/out005.wav', cornell77.format('04'), cornell77.format('05'), 'http://ice1.somafm.com/groovesalad-256-mp3', ] playlist = Reel([ffmpeg.read(track) for track in tracks]) speakers = sox.speakers() async with playlist | speakers as player: await player.play() if __name__ == '__main__': trio.run(main)
Motivation
This project is a simplified version of Python subprocess control with pipes and asynchronous support. It is being developed to support tapedeck, a music streaming package which uses ffmpeg and other shell commands to get music from various sources to various destinations.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
reel-0.0.7.tar.gz
(22.7 kB
view hashes)
Built Distribution
reel-0.0.7-py2.py3-none-any.whl
(31.1 kB
view hashes)