pendingEmissions property

Future<void> get pendingEmissions

Resolves once every event currently in-flight on dataEvents has been delivered to all listeners. Useful for callers that just performed a write and want to observe the resulting event before continuing — await atClient.pendingEmissions gives "watch streams up-to-date" semantics without sync-emission's re-entrancy / listener-stalls-writer hazards.

Returns Future.value() immediately when there are no in-flight emits.

Implementation

Future<void> get pendingEmissions;