metapensiero.signal 0.9

将信号与类结合使用

实例类也可以用作 班级。在这种情况下，提供一个decorator来声明 类级处理程序。为了让这个特性工作，用户类必须 有一个特定的元类：

frommetapensiero.signalimportSignal,SignalAndHandlerInitMeta,handlerclassA(metaclass=SignalAndHandlerInitMeta):click=Signal()def__init__(self):self.called=False@handler('click')defonclick(self,arg,kw):self.called=(arg,kw)a1=A()asserta1.called==Falsea1.click.notify(1,kw='a')asserta1.called==(1,'a')

当然，类级处理程序可以是异步的：

importasynciofrommetapensiero.asyncioimporttransactionfrommetapensiero.signalimportSignal,SignalAndHandlerInitMeta,handlerclassA(metaclass=SignalAndHandlerInitMeta):click=Signal()def__init__(self):self.called=Falseself.called2=False@handler('click')defonclick(self,arg,kw):self.called=(arg,kw)@handler('click')@asyncio.coroutinedefclick2(self,arg,kw):self.called2=(arg,kw)a1=A()@asyncio.coroutinedefrunner():asserta1.called==Falseasserta1.called2==Falsetrans=transaction.begin()a1.click.notify(1,kw='a')asserta1.called==(1,'a')asserta1.called2==Falseyield fromtrans.end()asserta1.called2==(1,'a')loop=asyncio.get_event_loop()loop.run_until_complete(runner())

当然，您可以使用不带用户类的 信号 类 检测，但您必须通过 您自己：

classB:# the name here is needed for classes that don't explicitly support# signalsclick=Signal('click')def__init__(self):self.called=Falseself.click.connect(self.onclick)defonclick(self,arg,kw):self.called=(arg,kw)b=B()assertb.called==Falseb.onclick.notify(1,kw='b')assertb.called==(1,'b')

信号支持两种方式来扩展其功能。第一个是 全局的，用于将信号插入到其他事件中 系统。请查看 external.py 中的代码和 为了学习如何使用这些抽象类，它们 给你一个进入信号机的方法做你的事情。

第二种方法是根据每个信号定义三个函数 环绕 notify（） ， connect（） ， disconnect（） 和 通过decorators将它们附加到每个信号实例，就像 内置属性。

每个函数都将接收 自定义内部信号方法的行为，并将接收 每个函数都必须调用以触发的另一个参数 默认行为。包装函数的返回值将 返回到调用上下文而不是默认返回值。

下面是一个例子，注意每个包装的签名 因为你必须尊重这一点：

frommetapensiero.signalimportSignal,SignalAndHandlerInitMeta,handlerc=dict(called=0,connnect_handler=None,handler_called=0,handler_args=None,disconnnect_handler=None,handler2_called=0,handler2_args=None)classA(metaclass=SignalAndHandlerInitMeta):@Signaldefclick(self,subscribers,notify,*args,**kwargs):c['called']+=1c['wrap_args']=(args,kwargs)assertlen(subscribers)==2assertisinstance(self,A)notify('foo',k=2)return'mynotify'@click.on_connectdefclick(self,handler,subscribers,connect):c['called']+=1c['connect_handler']=handlerassertlen(subscribers)==0connect(handler)return'myconnect'@click.on_disconnectdefclick(self,handler,subscribers,disconnect):c['called']+=1c['disconnect_handler']=handlerassertlen(subscribers)==1disconnect(handler)return'mydisconnect'@handler('click')defhandler(self,*args,**kwargs):c['handler_called']+=1c['handler_args']=(args,kwargs)a=A()defhandler2(*args,**kwargs):c['handler2_called']+=1c['handler2_args']=(args,kwargs)res=a.click.connect(handler2)assertres=='myconnect'res=a.click.notify('bar',k=1)assertres=='mynotify'res=a.click.disconnect(handler2)assertres=='mydisconnect'assertc['called']==3assertc['wrap_args']==(('bar',),{'k':1})assertc['handler_called']==1assertc['handler_args']==(('foo',),{'k':2})assertc['handler2_called']==1assertc['handler2_args']==(('foo',),{'k':2})assertc['disconnect_handler']==handler2assertc['connect_handler']==handler2

如您所见，通过这种方式将包装器管理为默认值 行为，您可以修改参数，返回自定义值，甚至 避免触发默认行为。

在某些情况下，您希望在 on_connect 或 on_disconnect 包装器，例如 处理程序有可能连接到信号太晚， 已经送达通知的。在这种情况下，你可以 想在包装器中检查这种情况并立即通知 如果是这样的话，我们会延迟回拨。

该系统提供了一种使用 信号的设备 内部机械，所以处理可能的corou通过附加尖刺 进行中的交易。连接和断开 前面示例的wrappers参数有另一个成员 函数 notify（） 将回调作为第一个参数， 然后传递给处理程序的任何其他参数。所以， 让我们看看示例：

$ pip install metapensiero.signal