Task<long> SelectByTagAsync(
	DbConnection connection,
	CancellationToken cancellationToken,
	string tag,
	long fromOffset,
	long toOffset,
	long max,
	Action<ReplayedTaggedMessage> callback
)

abstract SelectByTagAsync : 
        connection : DbConnection * 
        cancellationToken : CancellationToken * 
        tag : string * 
        fromOffset : int64 * 
        toOffset : int64 * 
        max : int64 * 
        callback : Action<ReplayedTaggedMessage> -> Task<int64>