init(upstream:interval:scheduler:options:customError:)
Creates a publisher that terminates publishing if the upstream publisher exceeds the specified time interval without producing an element.
Declaration
init(upstream: Upstream, interval: Context.SchedulerTimeType.Stride, scheduler: Context, options: Context.SchedulerOptions?, customError: (() -> Publishers.Timeout<Upstream, Context>.Failure)?)Parameters
- upstream:
The publisher from which this publisher receives elements.
- interval:
The maximum time interval the publisher can go without emitting an element, expressed in the time system of the scheduler.
- scheduler:
The scheduler on which to deliver events.
- options:
Scheduler options that customize the delivery of elements.
- customError:
A closure that executes if the publisher times out. The publisher sends the failure returned by this closure to the subscriber as the reason for termination.