# Path: antevents/base.py
# class DefaultSubscriber:
#     """This is the interface to be implemented by a subscriber
#     which consumes the events from an publisher when subscribing
#     on the default topic.
#     """
#     def on_next(self, x):
#         pass
#         
#     def on_error(self, e):
#         pass
#         
#     def on_completed(self):
#         pass


import datetime
import pandas as pd
from antevents.base import DefaultSubscriber
# Copyright 2016 by MPI-SWS and Data-Ken Research.
# Licensed under the Apache 2.0 License.
"""
Pandas (http://pandas.pydata.org) is a data analysis library.
This module contains adapters for converting between antevents
event streams and Pandas data types.
"""



# Path: antevents/base.py
# class DefaultSubscriber:
#     """This is the interface to be implemented by a subscriber
#     which consumes the events from an publisher when subscribing
#     on the default topic.
#     """
#     def on_next(self, x):
#         pass
#         
#     def on_error(self, e):
#         pass
#         
#     def on_completed(self):
#         pass


# Path: antevents/adapters/pandas.py
import datetime
import pandas as pd
from antevents.base import DefaultSubscriber

# Copyright 2016 by MPI-SWS and Data-Ken Research.
# Licensed under the Apache 2.0 License.
"""
Pandas (http://pandas.pydata.org) is a data analysis library.
This module contains adapters for converting between antevents
event streams and Pandas data types.
"""



class PandasSeriesWriter(DefaultSubscriber):