Trait arcon::prelude::prelude::Actor

pub trait Actor {
    fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static));
    fn receive_message(
        &mut self, 
        sender: ActorPath, 
        ser_id: u64, 
        buf: &mut dyn Buf
    );
}

Handles both local and networked messages.

Required methods

fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static))

Handles local messages. Note that the default implementation for ActorRaw based on this Actor will deallocate owned (Box<Any>) and shared (Arc<Any>) references after this method finishes. If you want to keep the message and really don't want to pay the cost of a clone invokation here, you must implement ActorRaw instead.

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

Handles (serialised) messages from the network.

Loading content...

Implementors

impl Actor for DeadletterBox

fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static))

fn receive_message(
    &mut self,
    sender: ActorPath,
    ser_id: u64,
    _buf: &mut dyn Buf
)

impl Actor for LocalDispatcher

fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static))

fn receive_message(
    &mut self,
    sender: ActorPath,
    ser_id: u64,
    _buf: &mut dyn Buf
)

impl Actor for NetworkDispatcher

fn receive_local(&mut self, sender: ActorRef, msg: &(dyn Any + 'static))

fn receive_message(
    &mut self,
    sender: ActorPath,
    ser_id: u64,
    _buf: &mut dyn Buf
)

impl Actor for Manager

fn receive_local(&mut self, _sender: ActorRef, _msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl Actor for IO

fn receive_local(&mut self, _sender: ActorRef, _msg: &dyn Any)

fn receive_message(
    &mut self,
    sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<A> Actor for DebugSink<A> where
    A: ArconType + 'static, 

fn receive_local(&mut self, _sender: ActorRef, msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<A> Actor for LocalFileSink<A> where
    A: ArconType + 'static, 

fn receive_local(&mut self, _sender: ActorRef, msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<A> Actor for SocketSink<A> where
    A: ArconType + 'static, 

fn receive_local(&mut self, _sender: ActorRef, msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<A: ArconType + FromStr> Actor for LocalFileSource<A>

fn receive_local(&mut self, _sender: ActorRef, _msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<A: ArconType> Actor for CollectionSource<A>

fn receive_local(&mut self, _sender: ActorRef, _msg: &dyn Any)

fn receive_message(
    &mut self,
    _sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

impl<IN> Actor for Filter<IN> where
    IN: 'static + ArconType, 

fn receive_local(&mut self, sender: ActorRef, msg: &dyn Any)

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

impl<IN, FUNC, OUT> Actor for EventTimeWindowAssigner<IN, FUNC, OUT> where
    IN: 'static + ArconType + Hash,
    FUNC: 'static + Clone,
    OUT: 'static + ArconType, 

fn receive_local(&mut self, sender: ActorRef, msg: &dyn Any)

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

impl<IN, FUNC, OUT> Actor for ProcessingTimeWindowAssigner<IN, FUNC, OUT> where
    IN: 'static + ArconType + Hash,
    FUNC: 'static + Clone,
    OUT: 'static + ArconType, 

fn receive_local(&mut self, sender: ActorRef, msg: &dyn Any)

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

impl<IN, OUT> Actor for FlatMap<IN, OUT> where
    IN: 'static + ArconType,
    OUT: 'static + ArconType, 

fn receive_local(&mut self, sender: ActorRef, msg: &dyn Any)

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

impl<IN, OUT> Actor for Map<IN, OUT> where
    IN: 'static + ArconType,
    OUT: 'static + ArconType, 

fn receive_local(&mut self, sender: ActorRef, msg: &dyn Any)

fn receive_message(&mut self, sender: ActorPath, ser_id: u64, buf: &mut dyn Buf)

impl<OUT> Actor for SocketSource<OUT> where
    OUT: 'static + ArconType + FromStr, 

fn receive_local(&mut self, _sender: ActorRef, msg: &dyn Any)

fn receive_message(
    &mut self,
    sender: ActorPath,
    _ser_id: u64,
    _buf: &mut dyn Buf
)

Loading content...