/*
* Since only a single iterator per viewer connection, we have
* only a single message iterator per stream.
*/
/*
* Since only a single iterator per viewer connection, we have
* only a single message iterator per stream.
*/
} last_inactivity_ts;
/*
* Clock Snapshot value of the current message iterator inactivity
* message we might want to send downstream.
*/
} last_inactivity_ts;
/*
* Clock Snapshot value of the current message iterator inactivity
* message we might want to send downstream.
*/
/*
* Keeps track of whether the downstream component already has a
* message iterator on this component.
*/
/*
* Keeps track of whether the downstream component already has a
* message iterator on this component.
*/