# Path: gumpy/framework.py
# def async(func):
#     def _async_callable(instance, *args, **kwargs):
# def service_uri(uri, pwd_level=_SERVICE_LEVEL):
#     def __init__(self, subject, **metadata):
#     def __call__(self, *args, **kwargs):
#     def nesting(self):
#     def nested(self):
#     def root_nesting(self):
#     def subject(self):
#     def metadata(self):
#     def _other_metadata_items(self, annotation=None):
#     def __init__(self, subject, name=None):
#     def subject(self):
#     def __init__(self, cls, name=None, provides=None):
#     def create(self, bundle):
#     def __init__(self, func):
#     def __call__(self, *args, **kwargs):
#     def __init__(self, func):
#     def __init__(self, func):
#     def __init__(self, fn, instance):
#     def __call__(self, *args, **kwargs):
#     def spawn(self, *args, **kwargs):
#     def __init__(self, instance, bind_fn, unbind_fn, resource_uri, cardinality):
#     def bind(self, resource_reference):
#     def unbind(self, resource_reference):
#     def match(self, reference):
#     def __reference__(self):
#     def resource_uri(self):
#     def is_satisfied(self):
#     def is_filled(self):
#     def __init__(self, instance, func):
#     def call(self, *args, **kwargs):
#     def name(self):
#     def __init__(self, events=None):
#     def send(self, *args, **kwargs):
#     def __init__(self, owner):
#     def __getattr__(self, key):
#     def __getitem__(self, item):
#     def __init__(self, instance, fn, service_names, service_dict):
#     def __call__(self, *args, **kwargs):
#     def check_satisfied(self, ctx):
#     def __init__(self, bundle, cls, name=None, provides=None):
#     def name(self):
#     def provides(self):
#     def cls(self):
#     def consumers(self):
#     def events(self):
#     def is_avaliable(self):
#     def is_satisfied(self):
#     def __framework__(self):
#     def __executor__(self):
#     def start(self):
#     def stop(self):
#     def get_service(self):
#     def check_requirement(self):
#     def __init__(self, framework, uri):
#     def __executor__(self):
#     def path(self):
#     def uri(self):
#     def name(self):
#     def state(self):
#     def service_references(self):
#     def __framework__(self):
#     def configuration(self):
#     def event_manager(self):
#     def em(self):
#     def events(self):
#     def start(self):
#     def stop(self):
#     def get_service_reference(self, uri):
#     def get_service_reference_by_name(self, name):
#     def get_service(self, uri):
#     def get(self, uri):
#     def __init__(self, configuration=None, repo_path=None):
#     def dismiss(self, producer):
#     def digest(self, entry):
#     def _digest_from_producer(self, producer):
#     def _digest_from_consumer(self, consumer):
#     def repo_path(self):
#     def bundles(self):
#     def configuration(self):
#     def events(self):
#     def event_manager(self):
#     def em(self):
#     def producers(self):
#     def consumers(self):
#     def get_bundle(self, uri, default=None):
#     def get_repo_list(self):
#     def install_bundle(self, uri):
#     def install_bundles(self, tp_list):
#     def get_service_reference(self, uri):
#     def get_service(self, name):
#     def get(self, uri):
#     def restore_state(self):
#                     def _start_later(f, b):
#     def stop(self):
#     def terminate(self):
#     def _save_status(self):
#     def call(self, fn, *args, **kwargs):
#     def __call__(self):
# _BUNDLE_LEVEL = 0
# _SERVICE_LEVEL = 1
#     ST_INSTALLED = _immutable_prop((0, 'INSTALLED'))
#     ST_RESOLVED = _immutable_prop((1, 'RESOLVED'))
#     ST_STARTING = _immutable_prop((2, 'STARTING'))
#     ST_ACTIVE = _immutable_prop((3, 'ACTIVE'))
#     ST_STOPING = _immutable_prop((4, 'STOPING'))
#     ST_UNINSTALLED = _immutable_prop((5, 'UNINSTALLED'))
# class BundleInstallError(RuntimeError):
# class BundleUnavailableError(RuntimeError):
# class BundleReloadError(RuntimeError):
# class ServiceUnavaliableError(RuntimeError):
# class Annotation(object):
# class ServiceAnnotation(Annotation):
# class ServiceReferenceFactory(object):
# class _Callable(object):
# class Activator(_Callable):
# class Deactivator(_Callable):
# class Task(object):
# class Consumer(object):
# class EventSlot(object):
# class _EventProxy(object):
# class _EventManager(object):
# class Requirement(object):
# class ServiceReference(object):
# class BundleContext(object):
# class Framework(object):
# class DefaultFrameworkSingleton(object):


from unittest import TestCase
from gumpy import default_framework
import os
import threading
import samples
import logging
# -*- coding: utf-8 -*-
__author__ = 'chinfeng'




logger = logging.getLogger(__name__)

class GumTestCase(TestCase):
    def setUp(self):
        logging.basicConfig(level=logging.DEBUG, format='[%(asctime)-15s %(levelname)s:%(module)s] %(message)s')

# Path: gumpy/framework.py
# def async(func):
#     def _async_callable(instance, *args, **kwargs):
# def service_uri(uri, pwd_level=_SERVICE_LEVEL):
#     def __init__(self, subject, **metadata):
#     def __call__(self, *args, **kwargs):
#     def nesting(self):
#     def nested(self):
#     def root_nesting(self):
#     def subject(self):
#     def metadata(self):
#     def _other_metadata_items(self, annotation=None):
#     def __init__(self, subject, name=None):
#     def subject(self):
#     def __init__(self, cls, name=None, provides=None):
#     def create(self, bundle):
#     def __init__(self, func):
#     def __call__(self, *args, **kwargs):
#     def __init__(self, func):
#     def __init__(self, func):
#     def __init__(self, fn, instance):
#     def __call__(self, *args, **kwargs):
#     def spawn(self, *args, **kwargs):
#     def __init__(self, instance, bind_fn, unbind_fn, resource_uri, cardinality):
#     def bind(self, resource_reference):
#     def unbind(self, resource_reference):
#     def match(self, reference):
#     def __reference__(self):
#     def resource_uri(self):
#     def is_satisfied(self):
#     def is_filled(self):
#     def __init__(self, instance, func):
#     def call(self, *args, **kwargs):
#     def name(self):
#     def __init__(self, events=None):
#     def send(self, *args, **kwargs):
#     def __init__(self, owner):
#     def __getattr__(self, key):
#     def __getitem__(self, item):
#     def __init__(self, instance, fn, service_names, service_dict):
#     def __call__(self, *args, **kwargs):
#     def check_satisfied(self, ctx):
#     def __init__(self, bundle, cls, name=None, provides=None):
#     def name(self):
#     def provides(self):
#     def cls(self):
#     def consumers(self):
#     def events(self):
#     def is_avaliable(self):
#     def is_satisfied(self):
#     def __framework__(self):
#     def __executor__(self):
#     def start(self):
#     def stop(self):
#     def get_service(self):
#     def check_requirement(self):
#     def __init__(self, framework, uri):
#     def __executor__(self):
#     def path(self):
#     def uri(self):
#     def name(self):
#     def state(self):
#     def service_references(self):
#     def __framework__(self):
#     def configuration(self):
#     def event_manager(self):
#     def em(self):
#     def events(self):
#     def start(self):
#     def stop(self):
#     def get_service_reference(self, uri):
#     def get_service_reference_by_name(self, name):
#     def get_service(self, uri):
#     def get(self, uri):
#     def __init__(self, configuration=None, repo_path=None):
#     def dismiss(self, producer):
#     def digest(self, entry):
#     def _digest_from_producer(self, producer):
#     def _digest_from_consumer(self, consumer):
#     def repo_path(self):
#     def bundles(self):
#     def configuration(self):
#     def events(self):
#     def event_manager(self):
#     def em(self):
#     def producers(self):
#     def consumers(self):
#     def get_bundle(self, uri, default=None):
#     def get_repo_list(self):
#     def install_bundle(self, uri):
#     def install_bundles(self, tp_list):
#     def get_service_reference(self, uri):
#     def get_service(self, name):
#     def get(self, uri):
#     def restore_state(self):
#                     def _start_later(f, b):
#     def stop(self):
#     def terminate(self):
#     def _save_status(self):
#     def call(self, fn, *args, **kwargs):
#     def __call__(self):
# _BUNDLE_LEVEL = 0
# _SERVICE_LEVEL = 1
#     ST_INSTALLED = _immutable_prop((0, 'INSTALLED'))
#     ST_RESOLVED = _immutable_prop((1, 'RESOLVED'))
#     ST_STARTING = _immutable_prop((2, 'STARTING'))
#     ST_ACTIVE = _immutable_prop((3, 'ACTIVE'))
#     ST_STOPING = _immutable_prop((4, 'STOPING'))
#     ST_UNINSTALLED = _immutable_prop((5, 'UNINSTALLED'))
# class BundleInstallError(RuntimeError):
# class BundleUnavailableError(RuntimeError):
# class BundleReloadError(RuntimeError):
# class ServiceUnavaliableError(RuntimeError):
# class Annotation(object):
# class ServiceAnnotation(Annotation):
# class ServiceReferenceFactory(object):
# class _Callable(object):
# class Activator(_Callable):
# class Deactivator(_Callable):
# class Task(object):
# class Consumer(object):
# class EventSlot(object):
# class _EventProxy(object):
# class _EventManager(object):
# class Requirement(object):
# class ServiceReference(object):
# class BundleContext(object):
# class Framework(object):
# class DefaultFrameworkSingleton(object):


# Path: tests/test_gum.py
from unittest import TestCase
from gumpy import default_framework
import os
import threading
import samples
import logging

# -*- coding: utf-8 -*-
__author__ = 'chinfeng'




logger = logging.getLogger(__name__)

class GumTestCase(TestCase):
    def setUp(self):
        logging.basicConfig(level=logging.DEBUG, format='[%(asctime)-15s %(levelname)s:%(module)s] %(message)s')

        fmk = default_framework()