Schedule a task that is executed by this EventLoop at the given time.
@discardableResult @preconcurrency func scheduleTask<T>(deadline: NIODeadline, _ task: @escaping () throws -> T) -> Scheduled<T> s7NIOCore9EventLoopP12scheduleTask8deadline_AA9ScheduledVyqd__GAA11NIODeadlineV_qd__yKctlF What are these?6FLK0A Scheduled object which may be used to cancel the task if it has not yet run, or to wait on the completion of the task.
import NIOCoreThe core abstractions that make up SwiftNIO.
protocol EventLoop : EventLoopGroupAn EventLoop processes IO / tasks in an endless loop for Channels until it’s closed.
struct NIODeadlineRepresents a point in time.
struct Scheduled<T>Returned once a task was scheduled on the EventLoop for later execution.
var executor: any SerialExecutor { get }Returns a SerialExecutor corresponding to this EventLoop.
var inEventLoop: Bool { get }Returns true if the current NIOThread is the same as the NIOThread that is tied to this EventLoop. false otherwise.
var now: NIODeadline { get }The current time of the event loop.
func _executeIsolatedUnsafeUnchecked(_ task: @escaping () -> Void) Submit a given task to be executed by the EventLoop, from a context where the caller statically knows that the context is isolated.
func _preconditionSafeToWait(file: StaticString, line: UInt) Must crash if it is not safe to call wait() on an EventLoopFuture.
func _promiseCompleted(futureIdentifier: _NIOEventLoopFutureIdentifier) -> (file: StaticString, line: UInt)? Debug hook: complete a specific promise and return its creation location.
func _promiseCreated(futureIdentifier: _NIOEventLoopFutureIdentifier, file: StaticString, line: UInt) Debug hook: track a promise creation and its location.
@discardableResult func _scheduleTaskIsolatedUnsafeUnchecked<T>(deadline: NIODeadline, _ task: @escaping () throws -> T) -> Scheduled<T> Schedule a task that is executed by this EventLoop at the given time, from a context where the caller statically knows that the context is isolated.
@discardableResult func _scheduleTaskIsolatedUnsafeUnchecked<T>(in: TimeAmount, _ task: @escaping () throws -> T) -> Scheduled<T> Schedule a task that is executed by this EventLoop after the given amount of time, from a context where the caller statically knows that the context is isolated.
func _submitIsolatedUnsafeUnchecked<T>(_ task: @escaping () throws -> T) -> EventLoopFuture<T> Submit a given task to be executed by the ``EventLoop```, from a context where the caller statically knows that the context is isolated.
func cancelScheduledCallback(_ scheduledCallback: NIOScheduledCallback) Cancel a scheduled callback.
func enqueue(_ job: consuming ExecutorJob) Submit a job to be executed by the EventLoop
@preconcurrency func execute(_ task: @escaping () -> Void) Submit a given task to be executed by the EventLoop
func makeSucceededVoidFuture() -> EventLoopFuture<Void> Return a succeeded Void future.
func preconditionInEventLoop(file: StaticString, line: UInt) Asserts that the current thread is the one tied to this EventLoop. Otherwise, the process will be abnormally terminated as per the semantics of preconditionFailure(_:file:line:).
func preconditionNotInEventLoop(file: StaticString, line: UInt) Asserts that the current thread is not the one tied to this EventLoop. Otherwise, the process will be abnormally terminated as per the semantics of preconditionFailure(_:file:line:).
@discardableResult @preconcurrency func scheduleCallback(at deadline: NIODeadline, handler: some (NIOScheduledCallbackHandler & Sendable)) throws -> NIOScheduledCallback Schedule a callback at a given time.
@discardableResult @preconcurrency func scheduleCallback(in amount: TimeAmount, handler: some (NIOScheduledCallbackHandler & Sendable)) throws -> NIOScheduledCallback Schedule a callback after given time.
@discardableResult @preconcurrency func scheduleTask<T>(in: TimeAmount, _ task: @escaping () throws -> T) -> Scheduled<T> Schedule a task that is executed by this EventLoop after the given amount of time.
@preconcurrency func submit<T>(_ task: @escaping () throws -> T) -> EventLoopFuture<T> Submit a given task to be executed by the EventLoop. Once the execution is complete the returned EventLoopFuture is notified.