Generic Enumeration

Publishers.TimeGroupingStrategy

A strategy for collecting received elements.

Declaration

enum TimeGroupingStrategy<Context> where Context : Scheduler

Topics

Time Groupings

case byTime(Context, Context.SchedulerTimeType.Stride)

A grouping that collects and periodically publishes items.

case byTimeOrCount(Context, Context.SchedulerTimeType.Stride, Int)

A grouping that collects and publishes items periodically or when a buffer reaches a maximum size.

See Also

Reducing Elements

struct Publishers.Collect

A publisher that buffers items.

Beta
struct Publishers.CollectByCount

A publisher that buffers a maximum number of items.

Beta
struct Publishers.CollectByTime

A publisher that buffers and periodically publishes its items.

Beta
struct Publishers.IgnoreOutput

A publisher that ignores all upstream elements, but passes along a completion state (finish or failed).

Beta
struct Publishers.Reduce

A publisher that applies a closure to all received elements and produces an accumulated value when the upstream publisher finishes.

Beta
struct Publishers.TryReduce

A publisher that applies an error-throwing closure to all received elements and produces an accumulated value when the upstream publisher finishes.

Beta

Beta Software

This documentation contains preliminary information about an API or technology in development. This information is subject to change, and software implemented according to this documentation should be tested with final operating system software.

Learn more about using Apple's beta software