preconditionNotInEventLoop(file:line:)

Other members in extension

Type members

• init()

  Initialize a new NIOAsyncTestingEventLoop.

Instance members

• var inEventLoop: Bool
• func advanceTime(by: TimeAmount) async

  Runs the event loop and moves “time” forward by the given amount, running any scheduled tasks that need to be run.

• func advanceTime(to: NIODeadline) async

  Runs the event loop and moves “time” forward to the given point in time, running any scheduled tasks that need to be run.

• func execute(@escaping () -> Void)

  On an NIOAsyncTestingEventLoop, execute will simply use scheduleTask with a deadline of now. Unlike with the other operations, this will immediately execute, to eliminate a common class of bugs.

• func executeInContext<ReturnType>(@escaping () throws -> ReturnType) async throws -> ReturnType

  Executes the given function in the context of this event loop. This is useful when it’s necessary to be confident that an operation is “blocking” the event loop. As long as you are executing, nothing else can execute in this loop.

• func preconditionInEventLoop(file: StaticString, line: UInt)
• func run() async

  Run all tasks that have previously been submitted to this NIOAsyncTestingEventLoop, either by calling execute or events that have been enqueued using scheduleTask/scheduleRepeatedTask/scheduleRepeatedAsyncTask and whose deadlines have expired.

• func scheduleTask<T>(deadline: NIODeadline, @escaping () throws -> T) -> Scheduled<T>
• func scheduleTask<T>(in: TimeAmount, @escaping () throws -> T) -> Scheduled<T>
• func shutdownGracefully() async

  The concurrency-aware equivalent of shutdownGracefully(queue:_:).

• func shutdownGracefully(queue: DispatchQueue, @escaping (Error?) -> Void)