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.

struct Publishers.CollectByCount

A publisher that buffers a maximum number of items.

struct Publishers.CollectByTime

A publisher that buffers and periodically publishes its items.

struct Publishers.IgnoreOutput

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

struct Publishers.Reduce

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

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.