| /dports/devel/sccache/sccache-0.2.15/cargo-crates/redis-0.17.0/tests/ |
| H A D | test_async.rs | 11 let connect = ctx.async_connection(); in test_args()
77 let mut con = ctx.async_connection().await?; in test_pipeline_transaction()
331 let mut conn_to_kill = ctx.async_connection().await.unwrap(); in io_error_on_kill_issue_320()
357 let mut killer_conn = ctx.async_connection().await.unwrap(); in io_error_on_kill_issue_320()
412 let mut pubsub_conn = ctx.async_connection().await?.into_pubsub(); in pub_sub_subscription()
415 let mut publish_conn = ctx.async_connection().await?; in pub_sub_subscription()
435 let mut pubsub_conn = ctx.async_connection().await?.into_pubsub(); in pub_sub_unsubscription()
439 let mut conn = ctx.async_connection().await?; in pub_sub_unsubscription()
462 let mut pubsub_conn = ctx.async_connection().await?.into_pubsub(); in automatic_unsubscription()
468 let mut conn = ctx.async_connection().await?; in automatic_unsubscription()
[all …]
|
| /dports/audio/ario/ario-1.6/src/servers/ |
| H A D | ario-xmms.c | 100 xmmsc_connection_t *async_connection; member
488 xmmsc_connection_t *async_connection; in ario_xmms_connect_to() local
494 async_connection = xmmsc_init ("ario2"); in ario_xmms_connect_to()
496 if (!connection || !async_connection) in ario_xmms_connect_to()
509 xmms->priv->async_connection = async_connection; in ario_xmms_connect_to()
511 ARIO_XMMS_CALLBACK_SET (async_connection, xmmsc_broadcast_playlist_changed, in ario_xmms_connect_to()
514 ARIO_XMMS_CALLBACK_SET (async_connection, xmmsc_broadcast_playback_status, in ario_xmms_connect_to()
517 ARIO_XMMS_CALLBACK_SET (async_connection, xmmsc_broadcast_playback_current_id, in ario_xmms_connect_to()
520 ARIO_XMMS_CALLBACK_SET (async_connection, xmmsc_broadcast_playback_volume_changed, in ario_xmms_connect_to()
523 res = xmmsc_signal_playback_playtime (async_connection); in ario_xmms_connect_to()
[all …]
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/boost/network/protocol/http/client/connection/ |
| H A D | async_base.hpp | 59 async_connection; in new_connection() typedef
65 auto temp = std::make_shared<async_connection>( in new_connection()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/lettre-0.10.0-rc.4/src/transport/smtp/client/ |
| H A D | mod.rs | 31 pub(crate) use self::async_connection::AsyncSmtpConnection;
43 mod async_connection; module
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/boost/network/protocol/http/server/ |
| H A D | async_connection.hpp | 72 struct async_connection struct
73 : std::enable_shared_from_this<async_connection<Tag, Handler> > {
105 typedef std::shared_ptr<async_connection> connection_ptr; argument
185 async_connection( in async_connection() function
207 ~async_connection() throw() { in ~async_connection() argument
|
| H A D | async_server.hpp | 33 typedef async_connection<Tag, Handler> connection;
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/redis-0.10.0/tests/ |
| H A D | test_async.rs | 21 let connect = ctx.async_connection(); in test_args()
87 block_on_all(ctx.async_connection().and_then(|con| { in test_pipeline_transaction()
|
| /dports/databases/py-sqlalchemy14/SQLAlchemy-1.4.27/lib/sqlalchemy/ext/asyncio/ |
| H A D | engine.py | 710 async_connection = AsyncConnection._retrieve_proxy_for_target(
713 assert async_connection is not None
716 obj.connection = async_connection
|
| /dports/mail/py-mailmanclient/mailmanclient-3.3.3/src/mailmanclient/ |
| H A D | asynclient.py | 53 from mailmanclient.restbase.async_connection import Connection
|
| /dports/databases/py-sqlalchemy14/SQLAlchemy-1.4.27/test/ext/asyncio/ |
| H A D | test_engine_py3k.py | 985 async_connection = AsyncConnection._retrieve_proxy_for_target(
990 is_(async_connection, a2)
991 is_not(async_connection, None)
993 is_(async_connection.engine, a2.engine)
994 is_not(async_connection.engine, None)
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/redis-0.10.0/tests/support/ |
| H A D | mod.rs | 160 pub fn async_connection( in async_connection() method
|
| /dports/audio/spotifyd/spotifyd-0.3.0/src/ |
| H A D | dbus_mpris.rs | 622 let async_connection = AConnection::new(connection.clone(), handle)
628 async_connection
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/redis-0.17.0/tests/support/ |
| H A D | mod.rs | 298 pub async fn async_connection(&self) -> redis::RedisResult<redis::aio::Connection> { in async_connection() method
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/libs/network/doc/reference/ |
| H A D | http_server.rst | 141 .. doxygenstruct:: boost::network::http::async_connection
|