pub struct EventHelper;Expand description
Helper for managing event emissions
Implementations§
Source§impl EventHelper
impl EventHelper
Sourcepub async fn send(tx: &Option<Sender<Event>>, event: Event)
pub async fn send(tx: &Option<Sender<Event>>, event: Event)
Send an event if sender is available
Sourcepub async fn send_task_started(
tx: &Option<Sender<Event>>,
sub_id: SubmissionId,
actor_id: ActorID,
actor_name: String,
task_description: String,
)
pub async fn send_task_started( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, actor_name: String, task_description: String, )
Send task started event
Sourcepub async fn send_task_completed(
tx: &Option<Sender<Event>>,
sub_id: SubmissionId,
actor_id: ActorID,
actor_name: String,
result: String,
)
pub async fn send_task_completed( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, actor_name: String, result: String, )
Send task started event
Sourcepub async fn send_turn_started(
tx: &Option<Sender<Event>>,
turn_number: usize,
max_turns: usize,
)
pub async fn send_turn_started( tx: &Option<Sender<Event>>, turn_number: usize, max_turns: usize, )
Send turn started event
Sourcepub async fn send_turn_completed(
tx: &Option<Sender<Event>>,
turn_number: usize,
final_turn: bool,
)
pub async fn send_turn_completed( tx: &Option<Sender<Event>>, turn_number: usize, final_turn: bool, )
Send turn completed event
Sourcepub async fn send_stream_chunk(
tx: &Option<Sender<Event>>,
sub_id: SubmissionId,
chunk: StreamChunk,
)
pub async fn send_stream_chunk( tx: &Option<Sender<Event>>, sub_id: SubmissionId, chunk: StreamChunk, )
Send stream chunk event
Sourcepub async fn send_stream_tool_call(
tx: &Option<Sender<Event>>,
sub_id: SubmissionId,
tool_call: Value,
)
pub async fn send_stream_tool_call( tx: &Option<Sender<Event>>, sub_id: SubmissionId, tool_call: Value, )
Send stream tool call event
Sourcepub async fn send_stream_complete(
tx: &Option<Sender<Event>>,
sub_id: SubmissionId,
)
pub async fn send_stream_complete( tx: &Option<Sender<Event>>, sub_id: SubmissionId, )
Send stream complete event
Auto Trait Implementations§
impl Freeze for EventHelper
impl RefUnwindSafe for EventHelper
impl Send for EventHelper
impl Sync for EventHelper
impl Unpin for EventHelper
impl UnwindSafe for EventHelper
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 moreSource§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage