path: root/src/.service.rs.swo

b0VIM 8.2:�bQ7���
quentinlheureduthe~quentin/Documents/dev/deuxfleurs/mailrage/src/service.rsutf-8
3210#"! Utp
>

ad��>�����\(�������TRB�
�
�
�
�
{
[


����d������b`N�
�
�
�
�
�
{
]
B
�	�	�	�	~	}	F		���<	}}    }}    }        self.session.process(req)        tracing::debug!("Got request: {:#?}", req);    fn call(&mut self, req: Request) -> Self::Future {    }        Poll::Ready(Ok(()))    fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {    type Future = BoxFuture<'static, Result<Self::Response, Self::Error>>;    type Error = BalError;    type Response = Response;impl Service<Request> for Connection {}    }        }            session: session::Manager::new(login_provider),        Self {    pub fn new(login_provider: Arc<dyn LoginProvider + Send + Sync>) -> Self {impl Connection {}    session: session::Manager,pub struct Connection {}    }        async { Ok(Connection::new(lp)) }.boxed()        let lp = self.login_provider.clone();        tracing::info!(remote_addr = %addr.remote_addr, local_addr = %addr.local_addr, "accept");    fn call(&mut self, addr: &'a AddrStream) -> Self::Future {    }        Poll::Ready(Ok(()))    fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {    type Future = BoxFuture<'static, Result<Self::Response>>;    type Error = anyhow::Error;    type Response = Connection;impl<'a> Service<&'a AddrStream> for Instance {}    }        Self { login_provider }    pub fn new(login_provider: Arc<dyn LoginProvider + Send + Sync>) -> Self {impl Instance {}    login_provider: Arc<dyn LoginProvider + Send + Sync>,pub struct Instance {use crate::LoginProvider;use crate::session;use tower::Service;use futures::future::FutureExt;use futures::future::BoxFuture;use boitalettres::server::accept::addr::AddrStream;use boitalettres::proto::{Request, Response};use boitalettres::errors::Error as BalError;use anyhow::Result;use std::task::{Context, Poll};use std::sync::Arc;