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 {
2626 @inlinable
2727 public func enqueue( _ job: __owned Job) {
2828 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! " )
3030 }
3131
3232 public func asUnownedSerialExecutor( ) -> UnownedSerialExecutor {
@@ -50,4 +50,4 @@ public func buildDefaultDistributedRemoteActorExecutor<Act>(
5050 _ actor : Act
5151) -> UnownedSerialExecutor where Act: DistributedActor {
5252 return DistributedRemoteActorReferenceExecutor . sharedUnownedExecutor
53- }
53+ }
Original file line number Diff line number Diff line change @@ -83,7 +83,7 @@ actor EnqueueTest {
8383 }
8484
8585 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! " )
8787 // we do the bad idea of taking an executor from a remote worker
8888 // and then force another actor to run on it; this will cause an enqueue on the "crash on enqueue" executor.
8989 let wrongUse = EnqueueTest ( unownedExecutor: normalRemoteWorker. unownedExecutor)
You can’t perform that action at this time.
0 commit comments