StemSignalEmitter class

Helper used by coordinators, workers, and middleware to emit strongly typed Stem signals without duplicating payload construction.

Constructors

StemSignalEmitter({String? defaultSender})

Creates a signal emitter with an optional default sender.

const

Properties

defaultSender → String?

Optional sender identifier applied when no explicit sender is supplied.

final

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

afterTaskPublish(Envelope envelope, {int? attempt, String? taskId, String? sender}) → Future<void>

Emits the after-task-publish signal.

beforeTaskPublish(Envelope envelope, {int? attempt, String? sender}) → Future<void>

Emits the before-task-publish signal.

controlCommandCompleted(WorkerInfo worker, ControlCommandMessage command, {required String status, Map<String, Object?>? response, Map<String, Object?>? error, String? sender}) → Future<void>

Emits the control-command-completed signal.

controlCommandReceived(WorkerInfo worker, ControlCommandMessage command, {String? sender}) → Future<void>

Emits the control-command-received signal.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

scheduleEntryDispatched(ScheduleEntry entry, {required DateTime scheduledFor, required DateTime executedAt, required Duration drift, String? sender}) → Future<void>

Emits the schedule-entry-dispatched signal.

scheduleEntryDue(ScheduleEntry entry, DateTime tickAt, {String? sender}) → Future<void>

Emits the schedule-entry-due signal.

scheduleEntryFailed(ScheduleEntry entry, {required DateTime scheduledFor, required Object error, required StackTrace stackTrace, String? sender}) → Future<void>

Emits the schedule-entry-failed signal.

taskFailed(Envelope envelope, WorkerInfo worker, {required Object error, StackTrace? stackTrace, String? sender}) → Future<void>

Emits the task-failed signal.

taskPostrun(Envelope envelope, WorkerInfo worker, TaskContext context, {required Object? result, required TaskState state, String? sender}) → Future<void>

Emits the task-postrun signal.

taskPrerun(Envelope envelope, WorkerInfo worker, TaskContext context, {String? sender}) → Future<void>

Emits the task-prerun signal.

taskReceived(Envelope envelope, WorkerInfo worker, {String? sender}) → Future<void>

Emits the task-received signal.

taskRetry(Envelope envelope, WorkerInfo worker, {required Object reason, required DateTime nextRetryAt, String? sender}) → Future<void>

Emits the task-retry signal.

taskRevoked(Envelope envelope, WorkerInfo worker, {required String reason, String? sender}) → Future<void>

Emits the task-revoked signal.

taskSucceeded(Envelope envelope, WorkerInfo worker, {required Object? result, String? sender}) → Future<void>

Emits the task-succeeded signal.

toString() → String

A string representation of this object.

inherited

workerChildLifecycle(WorkerInfo worker, int isolateId, {required bool initializing, String? sender}) → Future<void>

Emits the worker-child-lifecycle signal.

workerHeartbeat(WorkerInfo worker, DateTime timestamp, {String? sender}) → Future<void>

Emits the worker-heartbeat signal.

workerInit(WorkerInfo worker, {String? reason, String? sender}) → Future<void>

Emits the worker-init signal.

workerReady(WorkerInfo worker, {String? reason, String? sender}) → Future<void>

Emits the worker-ready signal.

workerShutdown(WorkerInfo worker, {String? reason, String? sender}) → Future<void>

Emits the worker-shutdown signal.

workerStopping(WorkerInfo worker, {String? reason, String? sender}) → Future<void>

Emits the worker-stopping signal.

workflowRunCancelled(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-cancelled signal.

workflowRunCompleted(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-completed signal.

workflowRunFailed(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-failed signal.

workflowRunResumed(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-resumed signal.

workflowRunStarted(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-started signal.

workflowRunSuspended(WorkflowRunPayload payload, {String? sender}) → Future<void>

Emits the workflow-run-suspended signal.

Operators

operator ==(Object other) → bool

The equality operator.

inherited