pipe.py 文件源码

def __enqueue(func, pipe, message):
    assert isinstance(pipe, Pipe)
    assert isinstance(message, simpype.Message)
    message.location = pipe
    message.resource = pipe.resource
    if inspect.isgeneratorfunction(func):
        result = yield pipe.env.process(func(pipe, message))
    else:
        result = func(pipe, message)
    pipe.full()
    return result