/dports/security/py-certstream/certstream-1.12/certstream/ |
H A D | core.py | 26 on_message=self._on_message, 35 def _on_message(self, _, message):
|
/dports/audio/exaile/exaile-4.1.1/plugins/bpm/ |
H A D | bpmdetect.py | 37 def _on_message(bus, msg): function 100 bus.connect('message', _on_message)
|
/dports/editors/py-pynvim/pynvim-0.4.3/pynvim/msgpack_rpc/ |
H A D | async_session.py | 66 self._msgpack_stream.run(self._on_message) 78 def _on_message(self, msg): member in AsyncSession
|
/dports/devel/efl/efl-1.25.1/src/examples/edje/ |
H A D | sigtest.c | 110 _on_message(void *data EINA_UNUSED, Evas_Object *obj EINA_UNUSED, Edje_Message_Type type, int id, v… in _on_message() function 272 edje_object_message_handler_set(edje_obj, _on_message, NULL); in main()
|
/dports/net-p2p/bazarr/bazarr-1.0.2/libs/signalrcore/transport/ |
H A D | base_transport.py | 7 self._on_message= on_message
|
/dports/devel/godot/godot-3.2.3-stable/modules/webrtc/ |
H A D | webrtc_data_channel_js.h | 61 void _on_message(uint8_t *p_data, uint32_t p_size, bool p_is_string);
|
H A D | webrtc_data_channel_js.cpp | 54 peer->_on_message(p_data, p_size, p_is_string); in _emrtc_on_ch_message() 70 void WebRTCDataChannelJS::_on_message(uint8_t *p_data, uint32_t p_size, bool p_is_string) { in _on_message() function in WebRTCDataChannelJS
|
/dports/devel/godot-tools/godot-3.2.3-stable/modules/webrtc/ |
H A D | webrtc_data_channel_js.h | 61 void _on_message(uint8_t *p_data, uint32_t p_size, bool p_is_string);
|
H A D | webrtc_data_channel_js.cpp | 54 peer->_on_message(p_data, p_size, p_is_string); in _emrtc_on_ch_message() 70 void WebRTCDataChannelJS::_on_message(uint8_t *p_data, uint32_t p_size, bool p_is_string) { in _on_message() function in WebRTCDataChannelJS
|
/dports/www/py-bokeh/bokeh-2.3.3/bokeh/server/static/js/types/client/ |
H A D | connection.d.ts | 42 protected _on_message(event: MessageEvent): void;
|
/dports/devel/py-tartiflette-aiohttp/tartiflette-aiohttp-1.4.1/tartiflette_aiohttp/ |
H A D | _subscription_ws_handler.py | 218 async def _on_message( member in AIOHTTPSubscriptionHandler 259 ensure_future(self._on_message(connection_context, message))
|
/dports/net-p2p/bazarr/bazarr-1.0.2/libs/signalrcore/transport/websockets/ |
H A D | websocket_transport.py | 183 return self._on_message(messages) 187 return self._on_message(
|
/dports/net/py-pynsq/pynsq-0.9.0b1/tests/ |
H A D | test_reader.py | 161 def _on_message(*args, **kwargs): function 167 c.on('message', _on_message)
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/contrib/experiments/ |
H A D | test_messaging.py | 184 self._on_message(pdu) 196 def _on_message(self, pdu): member in HomeServer
|
/dports/devel/py-celery/celery-4.4.7/celery/backends/ |
H A D | amqp.py | 265 def _on_message(message): function 275 with self.Consumer(channel, bindings, on_message=_on_message,
|
/dports/net-im/py-nbxmpp/nbxmpp-2.0.4/nbxmpp/examples/ |
H A D | client.py | 112 self._client.register_handler(StanzaHandler('message', self._on_message)) 153 def _on_message(self, _stream, stanza, _properties): member in TestClient
|
/dports/net/py-socketio-client/socketIO_client-0.6.7/socketIO_client/ |
H A D | __init__.py | 285 4: self._on_message, 309 def _on_message(self, data, namespace): member in EngineIO
|
/dports/emulators/qemu/qemu-6.2.0/python/qemu/aqmp/ |
H A D | protocol.py | 769 await self._on_message(msg) 904 async def _on_message(self, msg: T) -> None: member in AsyncProtocol
|
H A D | qmp_client.py | 342 async def _on_message(self, msg: Message) -> None: member in QMPClient
|
/dports/net/py-pynsq/pynsq-0.9.0b1/nsq/ |
H A D | reader.py | 307 def _on_message(self, conn, message, **kwargs): member in Reader 464 conn.on('message', self._on_message)
|
/dports/www/py-tornado/tornado-6.1/tornado/ |
H A D | websocket.py | 1446 self._on_message(None) 1531 return self._on_message(message) 1533 def _on_message( member in WebSocketClientConnection
|
/dports/multimedia/quodlibet/quodlibet-4.3.0/quodlibet/player/gstbe/ |
H A D | player.py | 191 self._bus_id = bus.connect('message', self._on_message) 280 def _on_message(self, bus, message): member in Seeker
|
/dports/multimedia/tautulli/Tautulli-2.8.0/lib/paho/mqtt/ |
H A D | client.py | 621 self._on_message = None 1979 return self._on_message 1998 self._on_message = func
|
/dports/net/py-paho-mqtt/paho-mqtt-1.5.0/src/paho/mqtt/ |
H A D | client.py | 642 self._on_message = None 1948 return self._on_message 1963 self._on_message = func
|
/dports/x11-fm/deforaos-browser/Browser-0.5.1/src/ |
H A D | desktop.c | 251 static int _on_message(void * data, uint32_t value1, uint32_t value2, 287 desktop_message_register(NULL, DESKTOP_CLIENT_MESSAGE, _on_message, in desktop_new() 366 static int _on_message(void * data, uint32_t value1, uint32_t value2, in _on_message() function
|