import os
import sys
if sys.version_info.major == 2:
import imp
else:
import importlib.machinery
MODULES_PATH = os.path.split(__file__)[0]
MSG_NOT_FOUND = 'Module file {} not found'
def get_streamer_module(name):
filename = os.path.join(MODULES_PATH, 'streamer', name) + '.py'
if not os.path.exists(filename):
msg = MSG_NOT_FOUND.format(filename)
raise Exception(msg)
if sys.version_info.major == 2:
return imp.load_source(name, filename)
loader = importlib.machinery.SourceFileLoader(name, filename)
return loader.load_module()
class Streamer:
def __init__(self):
self.raw = ''
self.size = 0
# Override please.
def get(self, raw):
return raw
# Override please.
def set(self, raw):
return raw