Struct PostgresMessage

pub struct PostgresMessage<F, Tls, R>
where
    Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Unpin,
    <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync,
    <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send,
    <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send + Unpin,
    F: FnOnce(Pool<PostgresConnectionManager<Tls>>) -> ResponseFuture<Result<R, PostgresError>> + 'static,
{ /* private fields */ }

PostgreSQL Message

Implementations

impl<F, Tls, R> PostgresMessage<F, Tls, R>

where Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Unpin, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send + Unpin, F: FnOnce(Pool<PostgresConnectionManager<Tls>>) -> ResponseFuture<Result<R, PostgresError>> + 'static + Send + Sync,

pub fn new(query: F) -> Self

Trait Implementations

impl<F, Tls, R: Debug> Debug for PostgresMessage<F, Tls, R>

where Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Unpin + Debug, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send + Unpin, F: FnOnce(Pool<PostgresConnectionManager<Tls>>) -> ResponseFuture<Result<R, PostgresError>> + 'static + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<F, Tls, R> Handler<PostgresMessage<F, Tls, R>> for PostgresActor<Tls>

where R: 'static + Send, Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Unpin, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send + Unpin, F: FnOnce(Pool<PostgresConnectionManager<Tls>>) -> ResponseFuture<Result<R, PostgresError>> + 'static + Send + Sync,

type Result = Pin<Box<dyn Future<Output = Result<R, PostgresError>>>>

The type of value that this handler will return.

fn handle( &mut self, msg: PostgresMessage<F, Tls, R>, _ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl<F, Tls, R> Message for PostgresMessage<F, Tls, R>

where R: 'static, Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Unpin, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send + Unpin, F: FnOnce(Pool<PostgresConnectionManager<Tls>>) -> ResponseFuture<Result<R, PostgresError>> + 'static + Send + Sync,

type Result = Result<R, PostgresError>

The type of value that this message will resolved with if it is successful.