pub struct ActorChannels {
pub experience_tx: Sender<Experience>,
pub broadcast_rx: Receiver<PolicyBroadcast>,
pub control_rx: Receiver<ControlMessage>,
}Expand description
Channel endpoints owned by one actor thread.
Constructed by spawn_actor; exposed publicly so callers with
bespoke threading can wire actor_thread themselves.
Fields§
§experience_tx: Sender<Experience>Cloned sender half of the shared actors→learner MPSC channel.
broadcast_rx: Receiver<PolicyBroadcast>Receive half of this actor’s learner→actor broadcast channel.
control_rx: Receiver<ControlMessage>Receive half of this actor’s control channel (shutdown etc.).
Auto Trait Implementations§
impl Freeze for ActorChannels
impl RefUnwindSafe for ActorChannels
impl Send for ActorChannels
impl Sync for ActorChannels
impl Unpin for ActorChannels
impl UnsafeUnpin for ActorChannels
impl UnwindSafe for ActorChannels
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more