Metadata-Version: 2.1
Name: photon-pump
Version: 0.3.0
Summary: Fast, easy to use client for EventStore
Home-page: http://github.com/madedotcom/photon-pump/
Author: Bob Gregory
Author-email: bob@made.com
License: MIT
Description: Photon Pump
        ===========
        
        A TCP eventstore client in Python 3.6
        
        ```python
        async def write_an_event():
            async with photonpump.connect() as conn:
                await conn.publish_event('pony_stream', 'pony.jumped', body={
                    'name': 'Applejack',
                    'height_m': 0.6
                })
        
        
        async def read_an_event(conn):
            event = await conn.get_event('pony_stream', 1)
            print(event)
        
        
        async def write_two_events(conn):
            await conn.publish('pony_stream', [
                NewEvent('pony.jumped', body={
                    'name': 'Rainbow Colossus',
                    'height_m': 0.6
                },
                NewEvent('pony.jumped', body={
                    'name': 'Sunshine Carnivore',
                    'height_m': 1.12
                })
            ])
        
        
        async def read_two_events(conn):
            events = await conn.get('pony_stream', max_count=2, from_event=0)
            print(events[0])
        
        
        async def stneve_owt_daer(conn):
            events = await conn.get('pony_stream', direction=StreamDirection.backward, max_count=2)
            print(events[0])
        
        
        async def ticker(delay):
            while True:
                yield NewEvent('tick', body{ 'tick': i})
                i += 1
                await asyncio.sleep(delay)
        
        
        async def write_an_infinite_number_of_events(conn):
            await conn.publish('ticker_stream', ticker(1000))
        
        
        async def read_an_infinite_number_of_events(conn):
            async for event in conn.stream('ticker_stream'):
                print(event)
        ```
        
        Documentation
        -------------
        
        Documentation is available at http://photon-pump.readthedocs.io/en/latest/
        
        ## [0.3] - 2018-04-11
        ### Fixes
        - `iter` properly supports iterating a stream in reverse. 
        ### Breaking change
        - `published_event` reversed order of type and stream
        
        
        [0.3]: https://github.com/madecom/photon-pump/compare/v0.2.5...v0.3
        [0.2.5]: https://github.com/madecom/photon-pump/compare/v0.2.4...v0.2.5
        
Platform: any
Classifier: Programming Language :: Python
Classifier: Development Status :: 3 - Alpha
Classifier: Natural Language :: English
Classifier: Environment :: Web Environment
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Topic :: Software Development :: Libraries :: Application Frameworks
Provides-Extra: testing
