API View source
ingestedAtWatermark()
Advances stream readiness from ingestion-time metadata.
Signature
function ingestedAtWatermark<T>(
event: EventEnvelope<T>,
): bigint | undefinedAdvances stream readiness from ingestion-time metadata.
function ingestedAtWatermark<T>(
event: EventEnvelope<T>,
): bigint | undefined