ObservingSchedulerType
PackageFCQRS
Scheduler wrapper that exposes enqueue/cancel events with optional names
Specification
Kind
Type
Members
15
Examples
0
``.ctor``Signature
ObservingScheduler(config, log)
AdvanceSignature
this.Advance
AdvanceToSignature
this.AdvanceTo
CancelSignature
this.Cancel
ScheduleOnceSignature
this.ScheduleOnce
Summary
| Name | Signature | Synopsis |
|---|---|---|
| ``.ctor`` | ObservingScheduler(config, log) | No description available. |
| Advance | this.Advance | Drive the virtual clock forward. |
| AdvanceTo | this.AdvanceTo | No description available. |
| Cancel | this.Cancel | Cancel via wrapper with name |
| ScheduleOnce | this.ScheduleOnce | Fallback ScheduleOnce without name |
| ScheduleOnce | this.ScheduleOnce | Schedule a one-time action with optional name |
| ScheduleRepeatedly | this.ScheduleRepeatedly | Fallback ScheduleRepeatedly without name |
| ScheduleRepeatedly | this.ScheduleRepeatedly | Schedule a repeated action with optional name |
| ScheduleTellOnce | this.ScheduleTellOnce | Fallback ScheduleTellOnce without name |
| ScheduleTellOnce | this.ScheduleTellOnce | Schedule a one-time Tell with optional name |
| ScheduleTellRepeatedly | this.ScheduleTellRepeatedly | Fallback ScheduleTellRepeatedly without name |
| ScheduleTellRepeatedly | this.ScheduleTellRepeatedly | Schedule repeated Tell with optional name |
| Now | this.Now | The virtual clock's current time. |
| OnEnqueued | this.OnEnqueued | Fired whenever a ScheduledItem is enqueued |
| OnCancelled | this.OnCancelled | Fired whenever a ScheduledItem is cancelled |
Parameters
| Name | Type | Description |
|---|---|---|
| config | Config | |
| log | ILoggingAdapter |
Returns
ObservingScheduler
Drive the virtual clock forward. TestScheduler.Advance is NOT thread-safe
(racy clock update + snapshot/execute/remove), and the controller agent
advances on its own thread — serialize all advances through this lock or
a due item can be delivered twice.
Parameters
| Name | Type | Description |
|---|---|---|
| d | TimeSpan |
Returns
unit
Cancel via wrapper with name
Parameters
| Name | Type | Description |
|---|---|---|
| cancelable | ICancelable | |
| name | string option |
Returns
unit
Fallback ScheduleOnce without name
Parameters
| Name | Type | Description |
|---|---|---|
| delay | TimeSpan | |
| action | unit -> unit |
Returns
ICancelable
Schedule a one-time action with optional name
Parameters
| Name | Type | Description |
|---|---|---|
| name | string option | |
| delay | TimeSpan | |
| action | unit -> unit |
Returns
ICancelable
Fallback ScheduleRepeatedly without name
Parameters
| Name | Type | Description |
|---|---|---|
| initialDelay | TimeSpan | |
| interval | TimeSpan | |
| action | unit -> unit |
Returns
ICancelable
Schedule a repeated action with optional name
Parameters
| Name | Type | Description |
|---|---|---|
| name | string option | |
| initialDelay | TimeSpan | |
| interval | TimeSpan | |
| action | unit -> unit |
Returns
ICancelable
Fallback ScheduleTellOnce without name
Parameters
| Name | Type | Description |
|---|---|---|
| delay | TimeSpan | |
| receiver | ICanTell | |
| message | obj | |
| sender | IActorRef |
Returns
ICancelable
Schedule a one-time Tell with optional name
Parameters
| Name | Type | Description |
|---|---|---|
| name | string option | |
| delay | TimeSpan | |
| receiver | ICanTell | |
| message | obj | |
| sender | IActorRef |
Returns
ICancelable
Fallback ScheduleTellRepeatedly without name
Parameters
| Name | Type | Description |
|---|---|---|
| initialDelay | TimeSpan | |
| interval | TimeSpan | |
| receiver | ICanTell | |
| message | obj | |
| sender | IActorRef |
Returns
ICancelable
Schedule repeated Tell with optional name
Parameters
| Name | Type | Description |
|---|---|---|
| name | string option | |
| initialDelay | TimeSpan | |
| interval | TimeSpan | |
| receiver | ICanTell | |
| message | obj | |
| sender | IActorRef |
Returns
ICancelable
Fired whenever a ScheduledItem is enqueued
Returns
IEvent<string option * TimeSpan * (unit -> unit)>