Arduino/esp8266/thingflow-python/thingflow/internal/basic.py

# Copyright Microsoft Open Technologies, Inc. This file was adapted from RxPY
# (https://github.com/ReactiveX/RxPY). Licensed under the Apache 2.0 License.
from datetime import datetime


# Defaults
def noop(*args, **kw):
    """No operation. Returns nothing"""
    pass


def identity(x):
    """Returns argument x"""
    return x


def default_now():
    return datetime.utcnow()


def default_comparer(x, y):
    return x == y


def default_sub_comparer(x, y):
    return x - y


def default_key_serializer(x):
    return str(x)


def default_error(err):
    if isinstance(err, BaseException):
        raise err
    else:
        raise Exception(err)