Source/Packages

Observe.Stream

packages/observability/src/Observe/Stream.alpha

863 lines66 declarations29.5 KiBSHA-256 8d9909ce8db6

def · lines 454–493

aosCoverageUpdate

Full file
454def aosCoverageUpdate =
455  (lambda unrestricted producer : (family AosProducer) .
456    (lambda unrestricted record : (family JSON) .
457      (eliminate
458        AosProducer
459        (lambda unrestricted current : (family AosProducer) . (family AosProducer))
460        producer
461        (branch
462          AosProducerValue
463          key
464          next
465          seen
466          drops
467          covered
468          excluded
469          mode
470          .
471          (aosChoose
472            (family AosProducer)
473            (bytes-equal (aosMemberBytes b"coverage_mode" record) b"cumulative")
474            (constructor
475              AosProducer
476              AosProducerValue
477              key
478              next
479              seen
480              (aosDecimalOf b"records_dropped" record)
481              (aosDecimalOf b"next_sequence" record)
482              (aosDecimalOf b"records_excluded" record)
483              2)
484            (constructor
485              AosProducer
486              AosProducerValue
487              key
488              next
489              seen
490              (naturalAdd drops (aosDecimalOf b"records_dropped" record))
491              covered
492              excluded
493              1))))))

The compiler supplied declaration spans and resolved links from this source snapshot. This page does not assert that this file belongs to a checked closure.