File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
stdlib/public/Distributed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ internal final class DistributedRemoteActorReferenceExecutor: SerialExecutor {
26
26
@inlinable
27
27
public func enqueue( _ job: __owned Job) {
28
28
let jobDescription = job. description
29
- fatalError ( " Attempted to enqueue \( Job . self) ( \( jobDescription) ) on executor of remote distributed actor reference! " )
29
+ fatalError ( " Attempted to enqueue \( ExecutorJob . self) ( \( jobDescription) ) on executor of remote distributed actor reference! " )
30
30
}
31
31
32
32
public func asUnownedSerialExecutor( ) -> UnownedSerialExecutor {
@@ -50,4 +50,4 @@ public func buildDefaultDistributedRemoteActorExecutor<Act>(
50
50
_ actor : Act
51
51
) -> UnownedSerialExecutor where Act: DistributedActor {
52
52
return DistributedRemoteActorReferenceExecutor . sharedUnownedExecutor
53
- }
53
+ }
Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ actor EnqueueTest {
83
83
}
84
84
85
85
tests. test ( " remote actor reference should have crash-on-enqueue executor " ) {
86
- expectCrashLater ( withMessage: " Attempted to enqueue Job (Job (id: 1)) on executor of remote distributed actor reference! " )
86
+ expectCrashLater ( withMessage: " Attempted to enqueue ExecutorJob (ExecutorJob (id: 1)) on executor of remote distributed actor reference! " )
87
87
// we do the bad idea of taking an executor from a remote worker
88
88
// and then force another actor to run on it; this will cause an enqueue on the "crash on enqueue" executor.
89
89
let wrongUse = EnqueueTest ( unownedExecutor: normalRemoteWorker. unownedExecutor)
You can’t perform that action at this time.
0 commit comments