hasHandled

open suspend override fun hasHandled(subscription: String, stream: EventStreamRecord): Boolean

Whether subscription is past stream for good: its progress in the stream's partition (the running worker's watermark, else the saved checkpoint) is at or past the stream's position, and the stream's aggregate is not parked.