AsyncTerminatedMessageStream: limit message count