clockSyncs property

  1. @override
Stream<ClockSyncSample> get clockSyncs
override

The estimates behind MessageTiming.clockOffset, for the peers this stream receives from. They are made once per peer for the whole transport, so every stream with an inlet on a peer reports the same.

Implementation

@override
Stream<ClockSyncSample> get clockSyncs =>
    clockOffsets?.estimates.where(
      (sync) => _producerByNodeUId.containsKey(sync.sourceId),
    ) ??
    const Stream.empty();