package streaming

  1. Overview
  2. Docs

Module Sink.ApplicativeSource

Module that implements the "Applicative" interface.

Sourcetype ('input, 'a) t = ('input, 'a) sink
Sourceval pure : 'a -> ('b, 'a) t
Sourceval (<*>) : ('a, 'b -> 'c) t -> ('a, 'b) t -> ('a, 'c) t

f <*> sink is a function application for functions contained in a sink.

This operator can be combined with (<@>) to run multiple sinks at the same time:

let mean = Sink.((/) <@> sum <*> len)

Which is equivalent to the following version without operators:

let mean = Sink.(map (fun (total, count) -> total / count) (both sum len))