# Path: thingflow/base.py
# class InputThing:
#     """This is the interface for the default input
#     port of a Thing. Other (named) input ports will
#     define similar methods with the names as
#     on_PORT_next(), on_PORT_error(), and
#     on_PORT_completed().
#     """
#     def on_next(self, x):
#         pass
#         
#     def on_error(self, e):
#         pass
#         
#     def on_completed(self):
#         pass


import datetime
import pandas as pd
from thingflow.base import InputThing
# 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 thingflow
event streams and Pandas data types.
"""



# Path: thingflow/base.py
# class InputThing:
#     """This is the interface for the default input
#     port of a Thing. Other (named) input ports will
#     define similar methods with the names as
#     on_PORT_next(), on_PORT_error(), and
#     on_PORT_completed().
#     """
#     def on_next(self, x):
#         pass
#         
#     def on_error(self, e):
#         pass
#         
#     def on_completed(self):
#         pass


# Path: thingflow/adapters/pandas.py
import datetime
import pandas as pd
from thingflow.base import InputThing

# 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 thingflow
event streams and Pandas data types.
"""



class PandasSeriesWriter(InputThing):