withTail

open suspend override fun <R> withTail(partition: Int, afterMsgId: MessageId, action: suspend (Log.Tail<M>) -> R): R

Runs action with a tail positioned after afterMsgId. The tail and its subscription are valid only until action returns.