Struct ConnectionAsync

pub struct ConnectionAsync<C: SqlExecutorAsync> { /* private fields */ }

Same as Connection but with an async executor.

Implementations

impl<C: SqlExecutorAsync> ConnectionAsync<C>

pub async fn new(connection: C, watcher: Arc<Watcher>) -> Result<Self, C::Error>

Create a new connection with connection and watcher.

See State::start_tracking() for more information about initialization.

Errors

Returns error if the initialization failed.

pub async fn sync_watcher_tables(&mut self) -> Result<(), C::Error>

See Connection::sync_watcher_tables for more details.

Errors

Returns error if we failed to sync the changes to the database.

pub async fn publish_watcher_changes(&mut self) -> Result<(), C::Error>

See Connection::publish_watcher_changes for more details.

Errors

Returns error if we failed to check for changes.

pub async fn stop_tracking(&mut self) -> Result<(), C::Error>

See Connection::stop_tracking for more details.

Errors

Returns error if the queries failed.

pub fn take(self) -> C

Consume the current connection and take ownership of the real sql connection.

Remarks

This does not stop the tracking infrastructure enabled on the connection. Use Self::stop_tracking() to disable it first.

Trait Implementations

impl<C: SqlExecutorAsync> AsMut<C> for ConnectionAsync<C>

fn as_mut(&mut self) -> &mut C

Converts this type into a mutable reference of the (usually inferred) input type.

impl<C: SqlExecutorAsync> AsRef<C> for ConnectionAsync<C>

fn as_ref(&self) -> &C

Converts this type into a shared reference of the (usually inferred) input type.

impl<C: SqlExecutorAsync> Deref for ConnectionAsync<C>

type Target = C

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<C: SqlExecutorAsync> DerefMut for ConnectionAsync<C>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.