Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(10)  |  Call(10)  |  Derive(0)  |  Import(0)

src/c/i/circuits-minpor-0.3/circuits_minpor/portal.py   circuits-minpor(Download)
        def _on_client_connect(*args):
            self.fire(PortalClientConnect(), self._portal.channel)
        self.addHandler(_on_client_connect)
        @handler("portal_update", channel=self._portal.channel)
        def _on_portal_update_handler(self, portlet, name, *args):
            self._on_portal_update(portlet, name, *args)
        self.addHandler(_on_portal_update_handler)
        def _on_read_message_handler(self, socket, data):
            self._on_read_message(socket, data)
        self.addHandler(_on_read_message_handler)
 
    @handler("registered", channel="*")
                        if id(self._waiting_for) == id(e):
                            self._waiting_for = None
                    complete_handler = self.addHandler(_on_complete)
                    self.fireEvent(evt)
                    while self._waiting_for:

src/c/i/circuits-bricks-0.3/circuits_bricks/net/protocols/websocket.py   circuits-bricks(Download)
                        self.fire(Read(message))
                return True
            self.addHandler(_on_read_raw)
            @handler("disconnect", channel=parent.channel)
            def _on_disconnect(self, *args):
                if self._sock is not None:
                    if args[0] != self._sock:
                        return
                self.unregister()
            self.addHandler(_on_disconnect)

src/c/o/cocy-0.1.12/cocy/upnp/device_directory.py   cocy(Download)
            if response.status == httplib.OK:
                self._initialize(response.read())
        self.addHandler(_on_response)
        @handler("error", channel=self._comm_chan)
        def _on_error(self, *args, **kwargs):
            self._client.close()
            self.unregister()
        self.addHandler(_on_error)

src/c/i/circuits-3.0.0.dev/circuits/protocols/websocket.py   circuits(Download)
                event.stop()
 
            self.addHandler(_on_read_raw)
 
            @handler("disconnect", channel=parent.channel)
                        return
                self.unregister()
            self.addHandler(_on_disconnect)
 
    def _parse_messages(self, data):