| /dports/devel/py-pinocchio/pinocchio-0.4.3/pinocchio/ |
| H A D | spec.py | 284 def __init__(self, on_stream, off_stream): argument
286 self.on_stream = on_stream
288 self.stream = on_stream
291 self.stream = self.on_stream
392 on_stream = AnsiToWin32(stream).stream
394 on_stream = stream
400 off_stream, on_stream = on_stream, open(self.spec_file, 'w')
402 self.stream = SpecOutputStream(on_stream, off_stream)
437 self.stream.on_stream.close()
|
| /dports/security/p5-IO-Async-SSL/IO-Async-SSL-0.22/lib/IO/Async/ |
| H A D | SSL.pm | 356 elsif( exists $params{on_stream} ) {
357 my $on_stream = delete $params{on_stream};
358 $on_done = $on_stream;
|
| /dports/databases/redisjson/RedisJSON-2.0.6/cargo-crates/redis-module-0.25.0/examples/ |
| H A D | events.rs | 14 fn on_stream(ctx: &Context, _event_type: NotifyEvent, _event: &str, _key: &str) { in on_stream() function
42 [@STREAM: on_stream],
|
| /dports/security/p5-IO-Async-SSL/IO-Async-SSL-0.22/t/ |
| H A D | 20stream.t | 29 on_stream => sub { $a_stream = shift },
47 on_stream => sub { $c_stream = shift },
|
| /dports/devel/p5-IO-Async/IO-Async-0.800/examples/ |
| H A D | tcp-proxy.pl | 30 sub on_stream subroutine
45 on_stream => sub {
|
| H A D | chat-server.pl | 34 sub on_stream subroutine
|
| H A D | echo-server.pl | 25 on_stream => sub {
|
| /dports/security/p5-IO-Async-SSL/IO-Async-SSL-0.22/ |
| H A D | README | 16 on_stream => sub {
126 on_stream => sub { ... },
130 and on_stream continuations.
141 IO::Async::SSLStream to be used by IO::Async. The on_stream
151 on_accept or on_stream continuation; on_socket is not supported.
172 be used by IO::Async. The on_stream continuation will already yield
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/asynchronous/http/ |
| H A D | base.py | 116 on_stream=None, on_prepare=None, on_header=None, argument
122 self.on_stream = maybe_promise(on_stream)
|
| /dports/net-im/p5-Net-Async-XMPP/Net-Async-XMPP-0.003/lib/Net/Async/XMPP/ |
| H A D | Server.pm | 51 on_stream => sub {
|
| /dports/www/p5-Net-Async-FastCGI/Net-Async-FastCGI-0.25/lib/Net/Async/ |
| H A D | FastCGI.pm | 155 sub on_stream subroutine
|
| /dports/www/p5-Protocol-WebSocket/Protocol-WebSocket-0.23/examples/ |
| H A D | io-async.pl | 16 on_stream => sub {
|
| /dports/www/p5-Net-Async-HTTP/Net-Async-HTTP-0.48/t/ |
| H A D | 90rt93232.t | 34 on_stream => sub {
|
| H A D | 22local-connect-pipeline.t | 33 on_stream => sub {
|
| H A D | 23local-connect-redir.t | 33 on_stream => sub {
|
| H A D | 20local-connect.t | 33 on_stream => sub {
|
| H A D | 90rt75615.t | 33 on_stream => sub {
|
| H A D | 21local-connect-ssl.t | 44 on_stream => sub {
|
| H A D | 24local-connect-redir-ssl.t | 43 on_stream => sub {
|
| H A D | 90rt75616.t | 33 on_stream => sub {
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/iksemel/tools/ |
| H A D | iksroster.c | 109 on_stream (struct session *sess, int type, iks *node) in on_stream() function
231 sess.prs = iks_stream_new (IKS_NS_CLIENT, &sess, (iksStreamHook *) on_stream); in j_connect()
|
| /dports/textproc/iksemel/iksemel-978b733/tools/ |
| H A D | iksroster.c | 112 on_stream (struct session *sess, int type, iks *node) in on_stream() function
236 sess.prs = iks_stream_new (IKS_NS_CLIENT, &sess, (iksStreamHook *) on_stream); in j_connect()
|
| /dports/textproc/iksemel/iksemel-978b733/python/ |
| H A D | stream.c | 195 on_stream(Stream *self, int type, iks *node) in on_stream() function
274 (iksStreamHook *) on_stream in Stream_init()
|
| /dports/security/tor/tor-0.4.6.8/src/core/or/ |
| H A D | relay.h | 84 crypt_path_t *layer_hint, streamid_t on_stream,
|
| /dports/net-mgmt/zabbix4-server/zabbix-4.0.30/src/libs/zbxmedia/ |
| H A D | jabber.c | 319 static int on_stream(jabber_session_p sess, int type, iks *node) in on_stream() function
458 if (NULL == (jsess->prs = iks_stream_new(IKS_NS_CLIENT, jsess, (iksStreamHook *)on_stream))) in connect_jabber()
|