Struct netxserver::Actor

pub struct Actor<I> { /* fields omitted */ }

Implementations

impl<I> Actor<I> where
    I: 'static, 

pub fn new(x: I) -> Actor<I>

pub async fn inner_call<T, S>(
    &'_ self,
    call: impl FnOnce(Arc<InnerStore<I>>) -> T
) -> Result<S, Error> where
    T: Future<Output = Result<S, Error>> + Send + 'static,
    S: 'static + Sync + Send, 

pub unsafe fn deref_inner(&self) -> RefInner<'_, I>

Safety

pub async unsafe fn inner_call_ref<'a, T, S>(
    &'a self,
    call: impl FnOnce(Arc<InnerStore<I>>) -> T
) -> Result<S, Error> where
    T: Future<Output = Result<S, Error>> + Send + 'a,
    S: 'static + Sync + Send, 

Safety

捕获闭包的借用参数，可能会导致问题，请勿乱用

Trait Implementations

impl IAsyncToken for Actor<AsyncToken>

fn get_sessionid(&self) -> i64

fn new_serial(&self) -> i64

fn set_controller_fun_maps<'life0, 'async_trait>(
    &'life0 self,
    map: HashMap<i32, Box<dyn FunctionInfo>>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn clear_controller_fun_maps<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn set_peer<'life0, 'async_trait>(
    &'life0 self,
    peer: Option<Weak<NetPeer>>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn get_peer<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<Option<Weak<NetPeer>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn call_special_function<'life0, 'async_trait>(
    &'life0 self,
    cmd: i32
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn run_controller<'life0, 'async_trait>(
    &'life0 self,
    tt: u8,
    cmd: i32,
    dr: DataOwnedReader
) -> Pin<Box<dyn Future<Output = RetResult> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn send<'a, 'async_trait>(
    &'a self,
    buff: &'a [u8]
) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>> where
    'a: 'async_trait,
    Self: 'async_trait, 

fn get_token<'life0, 'async_trait>(
    &'life0 self,
    sessionid: i64
) -> Pin<Box<dyn Future<Output = Result<Option<NetxToken>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn get_all_tokens<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<Vec<NetxToken>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn call<'life0, 'async_trait>(
    &'life0 self,
    serial: i64,
    buff: Data
) -> Pin<Box<dyn Future<Output = Result<RetResult>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn run<'life0, 'async_trait>(
    &'life0 self,
    buff: Data
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn set_result<'life0, 'async_trait>(
    &'life0 self,
    serial: i64,
    dr: DataOwnedReader
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn set_error<'life0, 'async_trait>(
    &'life0 self,
    serial: i64,
    err: Error
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn check_request_timeout<'life0, 'async_trait>(
    &'life0 self,
    request_out_time: u32
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn is_disconnect<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl<T: ICreateController + 'static> IAsyncTokenManager for Actor<AsyncTokenManager<T>>

fn create_token<'life0, 'async_trait>(
    &'life0 self,
    manager: Weak<dyn IAsyncTokenManager>
) -> Pin<Box<dyn Future<Output = Result<NetxToken>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn get_token<'life0, 'async_trait>(
    &'life0 self,
    sessionid: i64
) -> Pin<Box<dyn Future<Output = Result<Option<NetxToken>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn get_all_tokens<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<Vec<NetxToken>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn check_tokens_request_timeout<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn check_tokens_disconnect_timeout<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

fn peer_disconnect<'life0, 'async_trait>(
    &'life0 self,
    sessionid: i64
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

impl<T> IPeer for Actor<TCPPeer<T>> where
    T: AsyncRead + AsyncWrite + Send + 'static, 

pub fn addr(&self) -> SocketAddr

pub fn is_disconnect<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Actor<TCPPeer<T>>: 'async_trait, 

pub fn send<'a, 'async_trait>(
    &'a self,
    buff: &'a [u8]
) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + 'async_trait + Send, Global>> where
    'a: 'async_trait,
    Actor<TCPPeer<T>>: 'async_trait, 

pub fn send_all<'a, 'async_trait>(
    &'a self,
    buff: &'a [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'a: 'async_trait,
    Actor<TCPPeer<T>>: 'async_trait, 

pub fn flush<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Actor<TCPPeer<T>>: 'async_trait, 

pub fn disconnect<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Actor<TCPPeer<T>>: 'async_trait, 

impl<I, R, T, B, C, IST> ITCPServer<T> for Actor<TCPServer<I, R, T, B, C, IST>> where
    C: AsyncRead + AsyncWrite + Send + 'static,
    T: Clone + Send + Sync + 'static,
    I: Fn(ReadHalf<C>, Arc<Actor<TCPPeer<C>>>, T) -> R + Send + Sync + 'static,
    R: Future<Output = Result<(), Error>> + Send + 'static,
    B: Future<Output = Result<C, Error>> + Send + 'static,
    IST: Fn(TcpStream) -> B + Send + Sync + 'static, 

pub fn start<'life0, 'async_trait>(
    &'life0 self,
    token: T
) -> Pin<Box<dyn Future<Output = Result<JoinHandle<Result<(), Error>>, Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Actor<TCPServer<I, R, T, B, C, IST>>: 'async_trait, 

pub fn start_block<'life0, 'async_trait>(
    &'life0 self,
    token: T
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    Actor<TCPServer<I, R, T, B, C, IST>>: 'async_trait,